Hack around double-finalize issue

kuzudb · Aug 21, 2024 · 52a87d7 · 52a87d7
1 parent b49c0c9
commit 52a87d7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/include/processor/operator/physical_operator.h b/src/include/processor/operator/physical_operator.h
@@ -181,6 +181,8 @@ class PhysicalOperator {
     physical_op_vector_t children;
     ResultSet* resultSet;
     std::unique_ptr<OPPrintInfo> printInfo;
+
+    bool hasBeenFinalized = false;
 };
 
 } // namespace processor

diff --git a/src/processor/operator/physical_operator.cpp b/src/processor/operator/physical_operator.cpp
@@ -186,6 +186,10 @@ bool PhysicalOperator::getNextTuple(ExecutionContext* context) {
 }
 
 void PhysicalOperator::finalize(ExecutionContext* context) {
+    if (hasBeenFinalized) {
+        return;
+    }
+    hasBeenFinalized = true;
     if (!isSource()) {
         for (auto& child : children) {
             child->finalize(context);