summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhcpp <[email protected]>2022-03-23 00:55:53 +0300
committerhcpp <[email protected]>2022-03-23 00:55:53 +0300
commit9331f0b206a4c3af85a57752fa81a3a1f580af86 (patch)
tree7b3f4fc4d07fc1658af2bf034a4135a2ed68b4a0
parent0453c1d9bee8dd457e0553fc37d442e64c9ab3c7 (diff)
delete marked checkpoints full scan has been fixed YQ-990
ref:0c5d7b75e060963882505adbcbb09edb5a3b4aa5
-rw-r--r--ydb/core/yq/libs/checkpoint_storage/ydb_checkpoint_storage.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/yq/libs/checkpoint_storage/ydb_checkpoint_storage.cpp b/ydb/core/yq/libs/checkpoint_storage/ydb_checkpoint_storage.cpp
index 7799b52daaf..a5349371db9 100644
--- a/ydb/core/yq/libs/checkpoint_storage/ydb_checkpoint_storage.cpp
+++ b/ydb/core/yq/libs/checkpoint_storage/ydb_checkpoint_storage.cpp
@@ -1009,8 +1009,8 @@ TFuture<TIssues> TCheckpointStorage::DeleteMarkedCheckpoints(
SELECT
checkpoints_graphs_description.id AS id,
checkpoints_graphs_description.ref_count - refs.refs AS ref_count
- FROM {checkpoints_graphs_description_table_name}
- INNER JOIN (SELECT * FROM $refs) AS refs
+ FROM $refs AS refs
+ INNER JOIN {checkpoints_graphs_description_table_name}
ON refs.graph_description_id = checkpoints_graphs_description.id;
UPDATE {checkpoints_graphs_description_table_name}