File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
ydb/core/tx/columnshard/engines/reader/plain_reader/iterator Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -145,9 +145,9 @@ TStartMergeTask::TStartMergeTask(const std::shared_ptr<TMergingContext>& merging
145145
146146bool TContinueMergeTask::DoExecute () {
147147 TMemoryProfileGuard mGuard (" SCAN_PROFILE::MERGE::CONTINUE" , IS_DEBUG_LOG_ENABLED (NKikimrServices::TX_COLUMNSHARD_SCAN_MEMORY));
148- std::optional<NArrow::NMerger::TSortableBatchPosition > lastResultPosition = DrainMergerLinearScan (Context->ReadSequentiallyBufferSize );
148+ std::optional<NArrow::NMerger::TCursor > lastResultPosition = DrainMergerLinearScan (Context->ReadSequentiallyBufferSize );
149149 if (lastResultPosition) {
150- LastPK = lastResultPosition->ExtractSortingPosition ();
150+ LastPK = lastResultPosition->ExtractSortingPosition (MergingContext-> GetFinish (). GetSortFields () );
151151 }
152152 AFL_VERIFY (!!LastPK == (!!ResultBatch && ResultBatch->num_rows ()));
153153 PrepareResultBatch ();
You can’t perform that action at this time.
0 commit comments