Skip to content

Commit 6d22ef0

Browse files
commit off set ranges fix (#2380)
1 parent bf2e023 commit 6d22ef0

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ void TPartitionStreamImpl<UseMigrationProtocol>::Commit(ui64 startOffset, ui64 e
7777
Commits.EraseInterval(0, endOffset); // Drop only committed ranges;
7878
}
7979
for (auto range: toCommit) {
80-
sessionShared->Commit(this, range.first, range.second);
80+
sessionShared->Commit(this, range.first, Min(range.second, endOffset));
8181
}
8282
}
8383
}

ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/read_session_ut.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1579,8 +1579,8 @@ Y_UNIT_TEST_SUITE(ReadSessionImplTest) {
15791579
}
15801580
for (const auto& range : req.offset_ranges()) {
15811581
Cerr << "RANGE " << range.start_offset() << " " << range.end_offset() << "\n";
1582-
if (range.start_offset() == 10 && range.end_offset() == 12) has1 = true;
1583-
else if (range.start_offset() == 0 && range.end_offset() == 10) has2 = true;
1582+
if (range.start_offset() == 3 && range.end_offset() == 12) has1 = true;
1583+
else if (range.start_offset() == 0 && range.end_offset() == 3) has2 = true;
15841584
else UNIT_ASSERT(false);
15851585
}
15861586
}));

0 commit comments

Comments
 (0)