[Java] Localhost host used on transaction in bytecode queries about amazon-neptune-tools HOT 5 CLOSED

I was successfully able to reproduce the issue and I now see what you're referring to. The issue seems to be with the DriverRemoteConnection.tx() call when creating a Transaction object. That particular method uses client.getCluster(), [1] which we presently do not override in the GremlinClient class.

I'm looking at a fix that would create an overridden getCluster() method in the GremlinClient that would fetch an available Client (much like how the chooseConnection() method currently works) in order to return the parent Cluster object for that Client to return for the creation of the Transaction. I'll try to have something next week for review.

[1] https://github.com/apache/tinkerpop/blob/4c09ceef17611ca57e2faf4546960cac333d76f3/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/remote/DriverRemoteConnection.java#L282

from amazon-neptune-tools.

Can you say a bit more about how you are using this client library? Are you attempting to connect via localhost because you're using an SSH proxy to connect to Neptune?

Or are you trying to use Gremlin Server locally with this client?

from amazon-neptune-tools.

Yes of course, I try to test transactions with an AWS Neptune cluster which is in 1.2 version without a proxy (with a VPN access to the VPC). The gremlin driver is configured to call the Neptune cluster, and it works well on basic queries. But when I want to open a transaction like below, I got the exception and when I debug I can saw into GremlinCluster.connect() an initialization of a cluster which is used by transactions and not by standard queries (which use a connection into the clusterCollection if I understand well)

Initialization of the cluster with an host equal to localhost : line 57: Cluster parentCluster = clusterBuilder.apply(null);

final var vertex = traversalProvider.g().V().addV("myFirsNode").next(); // Work well and go into my Neptune cluster (I checked with a breakpoint and a query with the API outside of my test
final var transaction = traversalProvider.g().tx();
final GraphTraversalSource traversalInTransaction = transaction.begin();
traversalInTransaction.addV("myNewNode").addE("isConnectedTo").from(vertex).iterate()
transaction.commit();

from amazon-neptune-tools.

Ok super, thank you.

from amazon-neptune-tools.

Hi @Pred05 Thanks for reporting this. I've created a PR to fix this issue, and update the readme with an example:

#275

/cc @triggan

from amazon-neptune-tools.