summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authornsofya <[email protected]>2023-07-04 13:00:29 +0300
committernsofya <[email protected]>2023-07-04 13:00:29 +0300
commit6d0d6465b0cc13fa19e019b9f717be4d1bcb6b38 (patch)
tree4fa0ccc5a9a1f8b508529e649b9de732639de17e
parentac320528538f879e8504b62e6f7250e369fedcb8 (diff)
Correct blob constructor status processing
-rw-r--r--ydb/core/tx/columnshard/write_actor.cpp6
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);
}