Skip to content

Commit 4b2ee83

Browse files
fix build
1 parent db0989e commit 4b2ee83

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

ydb/core/formats/arrow/reader/merger.cpp

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -22,16 +22,15 @@ void TMergePartialStream::RemoveControlPoint() {
2222

2323
void TMergePartialStream::CheckSequenceInDebug(const TRWSortableBatchPosition& nextKeyColumnsPosition) {
2424
#ifndef NDEBUG
25-
auto nextCursor = nextKeyColumnsPosition.BuildSortingCursor();
2625
if (CurrentKeyColumns) {
27-
const bool linearExecutionCorrectness = CurrentKeyColumns->Compare(nextCursor) == std::partial_ordering::less;
26+
const bool linearExecutionCorrectness = nextKeyColumnsPosition.Compare(*CurrentKeyColumns) == std::partial_ordering::greater;
2827
if (!linearExecutionCorrectness) {
29-
const bool newSegmentScan = nextCursor.GetPosition() == 0;
30-
AFL_VERIFY(newSegmentScan && nextCursor.Compare(*CurrentKeyColumns) == std::partial_ordering::less)
31-
("merge_debug", DebugJson())("current_ext", nextCursor.DebugJson())("newSegmentScan", newSegmentScan);
28+
const bool newSegmentScan = nextKeyColumnsPosition.GetPosition() == 0;
29+
AFL_VERIFY(newSegmentScan && nextKeyColumnsPosition.Compare(*CurrentKeyColumns) == std::partial_ordering::less)
30+
("merge_debug", DebugJson())("current_ext", nextKeyColumnsPosition.DebugJson())("newSegmentScan", newSegmentScan);
3231
}
3332
}
34-
CurrentKeyColumns = nextKeyColumnsPosition;
33+
CurrentKeyColumns = nextKeyColumnsPosition.BuildSortingCursor();
3534
#else
3635
Y_UNUSED(nextKeyColumnsPosition);
3736
#endif

0 commit comments

Comments
 (0)