Invalidate consumed frames in ScanByPrimaryKey

2023-02-01 17:19:02 +01:00 · 2023-02-01 17:19:02 +01:00 · 41183b328b
commit 41183b328b
parent c9a0c15c16
1 changed files with 1 additions and 0 deletions
--- a/src/query/v2/plan/operator.cpp
+++ b/src/query/v2/plan/operator.cpp
@ -774,6 +774,7 @@ class DistributedScanByPrimaryKeyCursor : public Cursor {
              populated_any = true;
              ++output_frame_it;
            }
+            own_frames_it_->MakeInvalid();
          }
          break;
        }