HPCC-33436 Set offsetBranches to correct value in index write

Signed-off-by: Shamser Ahmed <[email protected]>
hpcc-systems · Feb 14, 2025 · 1bf6354 · 1bf6354
1 parent 8c73876
commit 1bf6354
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/thorlcr/activities/indexwrite/thindexwrite.cpp b/thorlcr/activities/indexwrite/thindexwrite.cpp
@@ -347,15 +347,17 @@ class IndexWriteActivityMaster : public CMasterActivity
 
                 offset_t slaveUncompressedSize;
                 offset_t slaveOriginalBlobSize;
+                offset_t offsetBranches;
                 mb.read(slaveUncompressedSize);
                 mb.read(slaveOriginalBlobSize);
+                mb.read(offsetBranches);
 
                 compressedFileSize += size;
                 uncompressedSize += slaveUncompressedSize;
                 originalBlobSize += slaveOriginalBlobSize;
 
                 props.setPropInt64("@uncompressedSize", slaveUncompressedSize);
-                props.setPropInt64("@offsetBranches", statsCollection.getStatisticSum(StSizeOffsetBranches));
+                props.setPropInt64("@offsetBranches", offsetBranches);
 
                 //Read details for the TLK if it has been generated
                 if (!singlePartKey && 0 == slaveIdx && buildTlk)

diff --git a/thorlcr/activities/indexwrite/thindexwriteslave.cpp b/thorlcr/activities/indexwrite/thindexwriteslave.cpp
@@ -616,7 +616,7 @@ class IndexWriteSlaveActivity : public ProcessSlaveActivity, public ILookAheadSt
             mb.append(partCrc);
             mb.append(uncompressedSize);
             mb.append(originalBlobSize);
-
+            mb.append(inactiveStats.getStatisticValue(StSizeOffsetBranches));
             if (!singlePartKey && firstNode() && buildTlk)
             {
                 mb.append(tlkCrc);