Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix log
Browse files Browse the repository at this point in the history
bobhan1 committed Dec 26, 2024
1 parent 2df0f17 commit cac72db
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions cloud/src/recycler/recycler.cpp
Original file line number Diff line number Diff line change
@@ -1551,14 +1551,13 @@ int InstanceRecycler::delete_rowset_data(const std::vector<doris::RowsetMetaClou
});
}
for (const auto& [resource_id, tablet_id, rowset_id] : rowsets_delete_by_prefix) {
LOG_INFO(
"delete rowset {} by prefix because it's in BEGIN_PARTIAL_UPDATE state, "
"resource_id={}, tablet_id={}, instance_id={}",
rowset_id, resource_id, tablet_id, instance_id_);
concurrent_delete_executor.add(
[&]() -> int { return delete_rowset_data(resource_id, tablet_id, rowset_id); });
}
if (!rowsets_delete_by_prefix.empty()) {
LOG_INFO("delete {} rowsets by prefix because they are in BEGIN_PARTIAL_UPDATE state",
rowsets_delete_by_prefix.size())
.tag("instance_id", instance_id_);
}
bool finished = true;
std::vector<int> rets = concurrent_delete_executor.when_all(&finished);
for (int r : rets) {

0 comments on commit cac72db

Please sign in to comment.