bug fix

kuzudb · May 17, 2023 · 76d408a · 76d408a
1 parent da50244
commit 76d408a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/src/include/common/vector/value_vector.h b/src/include/common/vector/value_vector.h
@@ -127,9 +127,8 @@ class ListVector {
             ->addList(listSize);
     }
     static inline void resetListAuxiliaryBuffer(ValueVector* vector) {
-        if (vector->dataType.typeID == VAR_LIST) {
-            reinterpret_cast<ListAuxiliaryBuffer*>(vector->auxiliaryBuffer.get())->resetSize();
-        }
+        assert(vector->dataType.typeID == VAR_LIST);
+        reinterpret_cast<ListAuxiliaryBuffer*>(vector->auxiliaryBuffer.get())->resetSize();
     }
 };
 

diff --git a/src/processor/operator/recursive_extend/recursive_join.cpp b/src/processor/operator/recursive_extend/recursive_join.cpp
@@ -19,6 +19,8 @@ void BaseRecursiveJoin::initLocalStateInternal(ResultSet* resultSet_, ExecutionC
     dstNodeIDVector = resultSet->getValueVector(dataInfo->dstNodePos).get();
     if (dataInfo->trackPath) {
         pathVector = resultSet->getValueVector(dataInfo->pathPos).get();
+    } else {
+        pathVector = nullptr;
     }
     initLocalRecursivePlan(context);
 }