How to close the connection to JanusGraph without exception?

524 views

Skip to first unread message

x...@infinait.eu

unread,

Oct 3, 2017, 7:24:54 AM10/3/17

to JanusGraph users

Hi All,

Every time I close the connection to our janus db, I get the following exception:

INFO (ConnectionPool.java:225) - Signalled closing of connection pool on Host{address=portal-ssl627-2.legendary-janusgraph-28.infinait.composedb.com/146.148.30.47:16138, hostUri=wss://portal-ssl627-2.legendary-janusgraph-28.infinait.composedb.com:16138/gremlin} with core size of 1

INFO (Connection.java:369) - Checking for pending messages to complete before close on org.apache.tinkerpop.gremlin.driver.Connection$CheckForPending@4b4cc069

WARN (Connection.java:322) - Timeout while trying to close connection on 2a5f4ec3-e1c5-4d9c-8ee2-a08ad92d2499 - force closing - server will close session on shutdown or expiration.

java.util.concurrent.TimeoutException

at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1771)

at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915)

at org.apache.tinkerpop.gremlin.driver.Connection.shutdown(Connection.java:317)

at org.apache.tinkerpop.gremlin.driver.Connection.tryShutdown(Connection.java:296)

at org.apache.tinkerpop.gremlin.driver.Connection.lambda$null$1(Connection.java:215)

at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656)

at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632)

at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

at java.util.concurrent.FutureTask.run(FutureTask.java:266)

at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)

at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

at java.lang.Thread.run(Thread.java:745)

The code is simple:

public class JanusConnectionTest {

private static final Map<String, Object> bindings;

static {

bindings = new HashMap<String, Object>();

bindings.put("graph_name", "infinAIt");

}

public static void main(String args[]) throws Exception {

String configFile = "conf\\compose.yaml";

Cluster cluster = Cluster.open(configFile);

Client client = cluster.connect(UUID.randomUUID().toString(), true);

client.init();

ResultSet rs = client.submit("def g = ConfiguredGraphFactory.open(graph_name); 0", bindings);

System.out.println(rs.one());

rs = client.submit("g.traversal().V().count()");

System.out.println(rs.one());

client.close();

cluster.close();

}

the yaml config file:

hosts: [portal-ssl627-2.legendary-janusgraph-28.infinait.composedb.com]

port:

username:

password:

connectionPool: { enableSsl: true }

serializer: { className: org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0, config: { serializeResultToString: true }}

I tried 3.2.5 and 3.3.0, the exception is same.

<groupId>org.apache.tinkerpop</groupId>

<artifactId>gremlin-driver</artifactId>

</dependency>

Perhaps the incorrect close cause our server memory leak. I am grateful for all the advice.

Robert Dale

unread,

Oct 4, 2017, 8:30:16 AM10/4/17

to x...@infinait.eu, JanusGraph users

Can you reproduce this on JanusGraph? Otherwise, you should create and issue with ComposeDB.

Robert Dale

--
You received this message because you are subscribed to the Google Groups "JanusGraph users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to janusgraph-users+unsubscribe@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/janusgraph-users/12e52518-1354-4a56-a7c2-e8f1dd8e6b8c%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

Reply all

Reply to author

Forward

0 new messages