alibaba / alibaba/GraphScope

[BUG] Unexpected results of Apply() + Count() in GIE

Open
#3,370 0 comments 0 reactions 1 assignee Claimed by @lnfjpt View on GitHub
Dominant language
C++
Stars
3.6k
Forks
468
Avg merge
29m
Merged PRs (30d)
1

Description

**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.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.