fix

ildar-khisambeev · ildar-khisambeev · commit 94e171a2c65b · 2024-03-01T11:58:49.000Z
diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp
@@ -77,7 +77,7 @@ void TPartitionStreamImpl<UseMigrationProtocol>::Commit(ui64 startOffset, ui64 e
             Commits.EraseInterval(0, endOffset); // Drop only committed ranges;
         }
         for (auto range: toCommit) {
-            sessionShared->Commit(this, range.first, range.second);
+            sessionShared->Commit(this, range.first, Min(range.second, endOffset));
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ void TPartitionStreamImpl<UseMigrationProtocol>::Commit(ui64 startOffset, ui64 e`
`77`	`77`	`Commits.EraseInterval(0, endOffset); // Drop only committed ranges;`
`78`	`78`	`}`
`79`	`79`	`for (auto range: toCommit) {`
`80`		`- sessionShared->Commit(this, range.first, range.second);`
	`80`	`+ sessionShared->Commit(this, range.first, Min(range.second, endOffset));`
`81`	`81`	`}`
`82`	`82`	`}`
`83`	`83`	`}`