diff options
| author | Bulat <[email protected]> | 2025-10-29 04:59:20 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-10-29 04:59:20 +0300 |
| commit | 017cbe9b2d0364e7a6c3922c3be64c20cc502810 (patch) | |
| tree | d458ed255be43667a9f683c2d10816e0491ac7b9 | |
| parent | 7c948ab9780c4458a78d1720571b42b4664f39c9 (diff) | |
[C++ SDK] Fixed infinite delay for blocking write session connect (#27747)
| -rw-r--r-- | ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp b/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp index 94143296287..c061d743385 100644 --- a/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp +++ b/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp @@ -107,7 +107,7 @@ TSimpleBlockingWriteSession::TSimpleBlockingWriteSession( subSettings.EventHandlers_.CommonHandler({}); } Writer = std::make_shared<TWriteSession>(subSettings, client, connections, dbDriverState); - Writer->Start(TDuration::Max()); + Writer->Start(TDuration::Zero()); } uint64_t TSimpleBlockingWriteSession::GetInitSeqNo() { |