janusgraph-users@lists.lfaidata.foundation | Thread goes into Waiting state forever

Home Messages Hashtags Subgroups Calendar

Date Date 1 - 3 of 3

Thread goes into Waiting state forever

hadoopmarc@...

Hi Tanroop,

Does the problem also occur if you replace v() with V().limit(1) inside your query?

If not, at what result size does your issue start to occur?

Btw, your post has a typo: "user" and "uidx" should be the same, but I assume it stems from anonymizing your query.

Marc

ssbothe3@...

#6206

Hi Tanroop,

I have also faced same issue and have posted a query about it on this channel 'GraphTraversal Thread Stuck'.

Did you found the root cause of above issue ?

Thanks,
Sujay Bothe

Tanroop Dhillon <dhillon...@...>

#4826

Hi,

I have following traversal,

Code:

GraphTraversal<Vertex, Map<String, Object >> vertexGraphTraversal = janusGraphConfig.getJanusGraph().traversal().V()

.has(VertexType.DEVICE.name(), PropertyEnum.ID.name(), TextP.startingWith(String.valueOf(devicePrefix)))

.as("devices").inE(EdgeType.LOGIN.name()).outV().hasLabel(VertexType.USER.name())

.as("users").select("devices","uidx").by(PropertyEnum.ID.name())

.by(PropertyEnum.ID.name());

while (vertexGraphTraversal.hasNext()){

next = vertexGraphTraversal.next();

curr_device = (String) next.get("devices");

curr_uidx = (String) next.get("uidx");

// Do some business logic / traverse

}

Problem

Threads go to waiting state

Stacktrace:

"pool-12-thread-3" #175 prio=5 os_prio=0 tid=0x00007f3de5732800 nid=0x1b9f0 in Object.wait() [0x00007f3c799f5000]

java.lang.Thread.State: WAITING (on object monitor)

at java.lang.Object.wait(Native Method)

at java.lang.Object.wait(Object.java:502)

at io.vavr.concurrent.FutureImpl$$Lambda$592/765826899.run(Unknown Source)

at io.vavr.control.Try.run(Try.java:105)

at io.vavr.concurrent.FutureImpl.await(FutureImpl.java:114)

- locked <0x00000006cdb56b98> (a java.lang.Object)

at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.interruptibleWait(CQLKeyColumnValueStore.java:308)

at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.getSlice(CQLKeyColumnValueStore.java:289)

at org.janusgraph.diskstorage.util.MetricInstrumentedStore.lambda$getSlice$0(MetricInstrumentedStore.java:104)

at org.janusgraph.diskstorage.util.MetricInstrumentedStore$$Lambda$606/587180314.call(Unknown Source)

at org.janusgraph.diskstorage.util.MetricInstrumentedStore.runWithMetrics(MetricInstrumentedStore.java:204)

at org.janusgraph.diskstorage.util.MetricInstrumentedStore.getSlice(MetricInstrumentedStore.java:103)

at org.janusgraph.diskstorage.keycolumnvalue.KCVSProxy.getSlice(KCVSProxy.java:76)

at org.janusgraph.diskstorage.BackendTransaction$1.call(BackendTransaction.java:271)

at org.janusgraph.diskstorage.BackendTransaction$1.call(BackendTransaction.java:268)

at org.janusgraph.diskstorage.util.BackendOperation.executeDirect(BackendOperation.java:68)

at org.janusgraph.diskstorage.util.BackendOperation.execute(BackendOperation.java:54)

at org.janusgraph.diskstorage.BackendTransaction.executeRead(BackendTransaction.java:469)

at org.janusgraph.diskstorage.BackendTransaction.edgeStoreQuery(BackendTransaction.java:268)

at org.janusgraph.graphdb.database.StandardJanusGraph.edgeQuery(StandardJanusGraph.java:440)

at org.janusgraph.graphdb.query.vertex.SimpleVertexQueryProcessor.lambda$null$0(SimpleVertexQueryProcessor.java:120)

at org.janusgraph.graphdb.query.vertex.SimpleVertexQueryProcessor$$Lambda$1036/1665748425.apply(Unknown Source)

at org.janusgraph.graphdb.query.profile.QueryProfiler.profile(QueryProfiler.java:99)

at org.janusgraph.graphdb.query.profile.QueryProfiler.profile(QueryProfiler.java:91)

at org.janusgraph.graphdb.query.profile.QueryProfiler.profile(QueryProfiler.java:83)

at org.janusgraph.graphdb.query.vertex.SimpleVertexQueryProcessor.lambda$getBasicIterator$1(SimpleVertexQueryProcessor.java:120)

at org.janusgraph.graphdb.query.vertex.SimpleVertexQueryProcessor$$Lambda$1032/1126366380.get(Unknown Source)

at org.janusgraph.graphdb.vertices.CacheVertex.loadRelations(CacheVertex.java:67)

at org.janusgraph.graphdb.query.vertex.SimpleVertexQueryProcessor.getBasicIterator(SimpleVertexQueryProcessor.java:120)

at org.janusgraph.graphdb.query.vertex.SimpleVertexQueryProcessor.iterator(SimpleVertexQueryProcessor.java:77)

at com.google.common.collect.Iterables$6.iterator(Iterables.java:689)

at org.janusgraph.graphdb.query.vertex.SimpleVertexQueryProcessor.vertexIds(SimpleVertexQueryProcessor.java:100)

at org.janusgraph.graphdb.query.vertex.BasicVertexCentricQueryBuilder.executeIndividualVertices(BasicVertexCentricQueryBuilder.java:336)

at org.janusgraph.graphdb.query.vertex.BasicVertexCentricQueryBuilder.executeVertices(BasicVertexCentricQueryBuilder.java:330)

at org.janusgraph.graphdb.query.vertex.BasicVertexCentricQueryBuilder$VertexConstructor.getResult(BasicVertexCentricQueryBuilder.java:241)

at org.janusgraph.graphdb.query.vertex.BasicVertexCentricQueryBuilder$VertexConstructor.getResult(BasicVertexCentricQueryBuilder.java:237)

at org.janusgraph.graphdb.query.vertex.VertexCentricQueryBuilder.execute(VertexCentricQueryBuilder.java:86)

at org.janusgraph.graphdb.query.vertex.VertexCentricQueryBuilder.vertices(VertexCentricQueryBuilder.java:114)

at org.janusgraph.graphdb.vertices.AbstractVertex.getVertexLabelInternal(AbstractVertex.java:125)

at org.janusgraph.graphdb.vertices.AbstractVertex.vertexLabel(AbstractVertex.java:130)

at org.janusgraph.graphdb.vertices.AbstractVertex.label(AbstractVertex.java:121)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.HasContainer.testLabel(HasContainer.java:114)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.HasContainer.test(HasContainer.java:85)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.HasContainer.testAll(HasContainer.java:180)

at org.apache.tinkerpop.gremlin.process.traversal.step.filter.HasStep.filter(HasStep.java:50)

at org.apache.tinkerpop.gremlin.process.traversal.step.filter.FilterStep.processNextStart(FilterStep.java:38)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep.hasNext(AbstractStep.java:143)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.ExpandableStepIterator.next(ExpandableStepIterator.java:50)

at org.apache.tinkerpop.gremlin.process.traversal.step.map.FlatMapStep.processNextStart(FlatMapStep.java:48)

at org.janusgraph.graphdb.tinkerpop.optimize.JanusGraphVertexStep.processNextStart(JanusGraphVertexStep.java:182)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep.hasNext(AbstractStep.java:143)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.ExpandableStepIterator.next(ExpandableStepIterator.java:50)

at org.apache.tinkerpop.gremlin.process.traversal.step.filter.FilterStep.processNextStart(FilterStep.java:37)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep.hasNext(AbstractStep.java:143)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.ExpandableStepIterator.next(ExpandableStepIterator.java:50)

at org.apache.tinkerpop.gremlin.process.traversal.step.map.MapStep.processNextStart(MapStep.java:36)

at org.apache.tinkerpop.gremlin.process.traversal.step.map.SelectStep.processNextStart(SelectStep.java:156)

at org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep.hasNext(AbstractStep.java:143)

at org.apache.tinkerpop.gremlin.process.traversal.util.DefaultTraversal.hasNext(DefaultTraversal.java:192)

at com.myntra.ats.linkedaccounts.batch.utils.MultiUserDevicesHelper.fetchForDevicesStartingWith(MultiUserDevicesHelper.java:57)

at com.myntra.ats.linkedaccounts.batch.utils.MultiUserDevicesHelper.run(MultiUserDevicesHelper.java:35)

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

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

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

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

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

Can someone please help here.

1 - 3 of 3

Previous Topic Next Topic

Home Hashtags Subgroups Calendar Terms