fix

ivanmorozov333 · ivanmorozov333 · commit 64d73d2fc476 · 2024-07-25T12:01:29.000+03:00
diff --git a/ydb/core/tx/columnshard/engines/changes/compaction/sparsed/logic.cpp b/ydb/core/tx/columnshard/engines/changes/compaction/sparsed/logic.cpp
@@ -68,7 +68,7 @@ bool TSparsedMerger::TCursor::AddIndexTo(const ui32 index, TWriter& writer) {
     if (index < NextGlobalPosition) {
         return false;
     } else if (index == NextGlobalPosition) {
-        if (index == Chunk->GetFinishPosition()) {
+        if (index == CommonShift + Chunk->GetRecordsCount()) {
             InitArrays(index);
             if (index != NextGlobalPosition) {
                 return false;
@@ -84,7 +84,7 @@ bool TSparsedMerger::TCursor::AddIndexTo(const ui32 index, TWriter& writer) {
         }
     }
     AFL_VERIFY(Chunk->GetStartPosition() <= index);
-    if (Chunk->GetFinishPosition() <= index) {
+    if (CommonShift + Chunk->GetRecordsCount() <= index) {
         InitArrays(index);
     }
     bool found = false;

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ bool TSparsedMerger::TCursor::AddIndexTo(const ui32 index, TWriter& writer) {`
`68`	`68`	`if (index < NextGlobalPosition) {`
`69`	`69`	`return false;`
`70`	`70`	`} else if (index == NextGlobalPosition) {`
`71`		`- if (index == Chunk->GetFinishPosition()) {`
	`71`	`+ if (index == CommonShift + Chunk->GetRecordsCount()) {`
`72`	`72`	`InitArrays(index);`
`73`	`73`	`if (index != NextGlobalPosition) {`
`74`	`74`	`return false;`
`@@ -84,7 +84,7 @@ bool TSparsedMerger::TCursor::AddIndexTo(const ui32 index, TWriter& writer) {`
`84`	`84`	`}`
`85`	`85`	`}`
`86`	`86`	`AFL_VERIFY(Chunk->GetStartPosition() <= index);`
`87`		`- if (Chunk->GetFinishPosition() <= index) {`
	`87`	`+ if (CommonShift + Chunk->GetRecordsCount() <= index) {`
`88`	`88`	`InitArrays(index);`
`89`	`89`	`}`
`90`	`90`	`bool found = false;`