diff options
| author | komels <komels@ydb.tech> | 2022-12-11 15:02:17 +0300 |
|---|---|---|
| committer | komels <komels@ydb.tech> | 2022-12-11 15:02:17 +0300 |
| commit | 2de63b7636c16c77c82af8239ca3b44d45b34a00 (patch) | |
| tree | fcf1737aa1f6b68fa634f4b9132ae86879853456 | |
| parent | bbf0f3f9d2b56853560647675b865b2416767ae9 (diff) | |
| download | ydb-2de63b7636c16c77c82af8239ca3b44d45b34a00.tar.gz | |
Another fix for SeqNo's
| -rw-r--r-- | ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp index 33e17f2bc36..24cf6651cd0 100644 --- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp +++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp @@ -311,12 +311,12 @@ ui64 TWriteSession::GetNextSeqNoImpl(const TMaybe<ui64>& seqNo) { "Cannot call write() with defined SeqNo on WriteSession running in auto-seqNo mode" ); - //! Disable SeqNo shift for manual SeqNo mode; - OnSeqNoShift = false; - SeqNoShift = 0; } else { seqNoValue = *seqNo; } + //! Disable SeqNo shift for manual SeqNo mode; + OnSeqNoShift = false; + SeqNoShift = 0; } else if (!(*AutoSeqNoMode)) { DbDriverState->Log.Write( TLOG_ERR, |