diff options
author | nsofya <[email protected]> | 2023-07-04 13:00:29 +0300 |
---|---|---|
committer | nsofya <[email protected]> | 2023-07-04 13:00:29 +0300 |
commit | 6d0d6465b0cc13fa19e019b9f717be4d1bcb6b38 (patch) | |
tree | 4fa0ccc5a9a1f8b508529e649b9de732639de17e | |
parent | ac320528538f879e8504b62e6f7250e369fedcb8 (diff) |
Correct blob constructor status processing
-rw-r--r-- | ydb/core/tx/columnshard/write_actor.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/ydb/core/tx/columnshard/write_actor.cpp b/ydb/core/tx/columnshard/write_actor.cpp index 7b85892a59b..ce6f5a05a7c 100644 --- a/ydb/core/tx/columnshard/write_actor.cpp +++ b/ydb/core/tx/columnshard/write_actor.cpp @@ -94,7 +94,11 @@ public: } auto status = NOlap::IBlobConstructor::EStatus::Finished; - while (BlobsConstructor->BuildNext() == NOlap::IBlobConstructor::EStatus::Ok) { + while (true) { + status = BlobsConstructor->BuildNext(); + if (status != NOlap::IBlobConstructor::EStatus::Ok) { + break; + } auto blobId = SendWriteBlobRequest(BlobsConstructor->GetBlob(), ctx); BlobsConstructor->RegisterBlobId(blobId); } |