diff options
| author | ivanmorozov <ivanmorozov@ydb.tech> | 2023-12-14 16:24:36 +0300 |
|---|---|---|
| committer | ivanmorozov <ivanmorozov@ydb.tech> | 2023-12-14 17:37:48 +0300 |
| commit | cb6b98b1a44c148f4c36428fc82066613fc68e54 (patch) | |
| tree | b9bcaed05596129ec1c4b54e1f57e904837a8cd4 | |
| parent | a14823b7b2576a04da188c0bebccc0e92355f138 (diff) | |
| download | ydb-cb6b98b1a44c148f4c36428fc82066613fc68e54.tar.gz | |
KIKIMR-20009:dont remove blobs in case failed main data writing
| -rw-r--r-- | ydb/core/tx/columnshard/blobs_action/bs/remove.h | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/ydb/core/tx/columnshard/blobs_action/bs/remove.h b/ydb/core/tx/columnshard/blobs_action/bs/remove.h index eb35653aa8..853dc16a15 100644 --- a/ydb/core/tx/columnshard/blobs_action/bs/remove.h +++ b/ydb/core/tx/columnshard/blobs_action/bs/remove.h @@ -15,9 +15,11 @@ protected: } - virtual void DoOnExecuteTxAfterRemoving(NColumnShard::TColumnShard& /*self*/, NColumnShard::TBlobManagerDb& dbBlobs, const bool /*success*/) { - for (auto&& i : GetDeclaredBlobs()) { - Manager->DeleteBlob(i, dbBlobs); + virtual void DoOnExecuteTxAfterRemoving(NColumnShard::TColumnShard& /*self*/, NColumnShard::TBlobManagerDb& dbBlobs, const bool success) { + if (success) { + for (auto&& i : GetDeclaredBlobs()) { + Manager->DeleteBlob(i, dbBlobs); + } } } virtual void DoOnCompleteTxAfterRemoving(NColumnShard::TColumnShard& /*self*/) { |