tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix DistributedExpandCursor

Browse Source
This commit is contained in:
János Benjamin Antal 2023-01-20 21:38:35 +01:00
parent c9299a6c72
commit 0eee3ad7b7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/query/v2/plan/operator.cpp
View File

@ -2890,7 +2890,7 @@ class DistributedExpandCursor : public Cursor {
}
bool PullInputFrames(ExecutionContext &context) {
const auto pulled_any = !input_cursor_->PullMultiple(*own_multi_frame_, context);
const auto pulled_any = input_cursor_->PullMultiple(*own_multi_frame_, context);
// These needs to be updated regardless of the result of the pull, otherwise the consumer and iterator might
// get corrupted because of the operations done on our MultiFrame.
own_frames_consumer_ = own_multi_frame_->GetValidFramesConsumer();
@ -2949,7 +2949,7 @@ class DistributedExpandCursor : public Cursor {
if (own_frames_it_ == own_frames_consumer_->end()) {
state_ = State::PullInputAndEdges;
} else {
InitEdges(*own_frames_it_, context);
InitEdgesMultiple(context);
state_ = State::PopulateOutput;
}
break;