diff options
author | hcpp <[email protected]> | 2022-03-23 00:55:53 +0300 |
---|---|---|
committer | hcpp <[email protected]> | 2022-03-23 00:55:53 +0300 |
commit | 9331f0b206a4c3af85a57752fa81a3a1f580af86 (patch) | |
tree | 7b3f4fc4d07fc1658af2bf034a4135a2ed68b4a0 | |
parent | 0453c1d9bee8dd457e0553fc37d442e64c9ab3c7 (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.cpp | 4 |
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} |