Skip to content

Commit 432fd2a

Browse files
fix
1 parent 13c2cbd commit 432fd2a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/tx/columnshard/engines/changes/general_compaction.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -189,13 +189,13 @@ void TGeneralCompactColumnEngineChanges::BuildAppendedPortionsByChunks(TConstruc
189189
ui32 recordIdx = 0;
190190
for (auto&& i : packs) {
191191
TGeneralSerializedSlice slice(std::move(i));
192-
auto b = batchResult->Slice(recordIdx, slice.GetRecordsCountVerified());
192+
auto b = batchResult->Slice(recordIdx, slice.GetRecordsCount());
193193
std::vector<std::vector<std::shared_ptr<IPortionDataChunk>>> chunksByBlobs = slice.GroupChunksByBlobs();
194194
AppendedPortions.emplace_back(TPortionInfoWithBlobs::BuildByBlobs(chunksByBlobs, nullptr, GranuleMeta->GetPathId(), resultSchema->GetSnapshot(), SaverContext.GetStorageOperator()));
195195
NArrow::TFirstLastSpecialKeys primaryKeys(slice.GetFirstLastPKBatch(resultSchema->GetIndexInfo().GetReplaceKey()));
196196
NArrow::TMinMaxSpecialKeys snapshotKeys(b, TIndexInfo::ArrowSchemaSnapshot());
197197
AppendedPortions.back().GetPortionInfo().AddMetadata(*resultSchema, primaryKeys, snapshotKeys, SaverContext.GetTierName());
198-
recordIdx += slice.GetRecordsCountVerified();
198+
recordIdx += slice.GetRecordsCount();
199199
}
200200
}
201201
}

0 commit comments

Comments
 (0)