aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@ydb.tech>2023-12-14 16:24:36 +0300
committerivanmorozov <ivanmorozov@ydb.tech>2023-12-14 17:37:48 +0300
commitcb6b98b1a44c148f4c36428fc82066613fc68e54 (patch)
treeb9bcaed05596129ec1c4b54e1f57e904837a8cd4
parenta14823b7b2576a04da188c0bebccc0e92355f138 (diff)
downloadydb-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.h8
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*/) {