GraphScope
GraphScope copied to clipboard
[BUG] Unexpected results of Apply() + Count() in GIE
Describe the bug
The following queries would occurs panic in Pegasus, on LDBC dataset:
gremlin> g.V().hasLabel("PERSON").limit(10).where(__.in("HASCREATOR").out("REPLYOF").count().is(0))
Status{code=UNKNOWN, description=execution_error: system error: kind(IOError), caused by:IOError(kind=System(ConnectionAborted)), occurred at: /workspaces/GraphScope/interactive_engine/executor/engine/pegasus/pegasus/src/data_plane/intra_process.rs:99, caused by connection aborted ;, cause=null}
gremlin> g.V().hasLabel("PERSON").limit(10).as("p1").select("p1").by(__.in("HASCREATOR").out("REPLYOF").dedup().count())
Status{code=UNKNOWN, description=execution_error: system error: kind(IOError), caused by:IOError(kind=System(ConnectionAborted)), occurred at: /workspaces/GraphScope/interactive_engine/executor/engine/pegasus/pegasus/src/data_plane/intra_process.rs:130, caused by connection aborted ;, cause=null}
The error log in pegasus is as below:
thread 'reactor 26' panicked at 'assertion failed: end.peers_contains(self.src)', /workspaces/GraphScope/interactive_engine/executor/engine/pegasus/pegasus/src/communication/decorator/exchange.rs:662:9
To Reproduce Start GIE with LDBC dataset (sf=1), with server_num = 1, and worker_num = 32, and the run the above queries.