update

kuzudb · Sep 7, 2023 · df12bfe · df12bfe
1 parent f3a6a6e
commit df12bfe
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/storage/copier/node_group.cpp b/src/storage/copier/node_group.cpp
@@ -40,8 +40,10 @@ uint64_t NodeGroup::append(
     auto numValuesToAppendInChunk =
         std::min(numValuesToAppend, StorageConstants::NODE_GROUP_SIZE - numNodes);
     auto serialSkip = 0u;
-    auto originalVectorSize = resultSet->getDataChunk(0)->state->selVector->selectedSize;
-    resultSet->getDataChunk(0)->state->selVector->selectedSize = numValuesToAppendInChunk;
+    auto originalVectorSize =
+        resultSet->getDataChunk(dataPoses[0].dataChunkPos)->state->selVector->selectedSize;
+    resultSet->getDataChunk(dataPoses[0].dataChunkPos)->state->selVector->selectedSize =
+        numValuesToAppendInChunk;
     for (auto i = 0u; i < chunks.size(); i++) {
         auto chunk = chunks[i].get();
         if (chunk->getDataType().getLogicalTypeID() == common::LogicalTypeID::SERIAL) {
@@ -51,7 +53,8 @@ uint64_t NodeGroup::append(
         auto dataPos = dataPoses[i - serialSkip];
         chunk->append(resultSet->getValueVector(dataPos).get(), numNodes, numValuesToAppendInChunk);
     }
-    resultSet->getDataChunk(0)->state->selVector->selectedSize = originalVectorSize;
+    resultSet->getDataChunk(dataPoses[0].dataChunkPos)->state->selVector->selectedSize =
+        originalVectorSize;
     numNodes += numValuesToAppendInChunk;
     return numValuesToAppendInChunk;
 }