This is an automated email from the ASF dual-hosted git repository.
w41ter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 611cd8ef9f5 [chore](cloud) adjust snapshot data migrator and chain
compactor scan interval (#61622)
611cd8ef9f5 is described below
commit 611cd8ef9f5dbf8afe0b56f65aeed60598376312
Author: walter <[email protected]>
AuthorDate: Tue Mar 24 10:51:23 2026 +0800
[chore](cloud) adjust snapshot data migrator and chain compactor scan
interval (#61622)
---
cloud/src/recycler/snapshot_chain_compactor.cpp | 7 +------
cloud/src/recycler/snapshot_data_migrator.cpp | 5 -----
2 files changed, 1 insertion(+), 11 deletions(-)
diff --git a/cloud/src/recycler/snapshot_chain_compactor.cpp
b/cloud/src/recycler/snapshot_chain_compactor.cpp
index f25a12e6569..49e5f31cb74 100644
--- a/cloud/src/recycler/snapshot_chain_compactor.cpp
+++ b/cloud/src/recycler/snapshot_chain_compactor.cpp
@@ -123,11 +123,6 @@ void SnapshotChainCompactor::scan_instance_loop() {
while (!stopped()) {
std::vector<InstanceInfoPB> instances;
get_all_instances(txn_kv_.get(), instances);
- LOG(INFO) << "Snapshot chain compactor get instances: " <<
[&instances] {
- std::stringstream ss;
- for (auto& i : instances) ss << ' ' << i.instance_id();
- return ss.str();
- }();
if (!instances.empty()) {
// enqueue instances
std::lock_guard lock(mtx_);
@@ -144,7 +139,7 @@ void SnapshotChainCompactor::scan_instance_loop() {
}
{
std::unique_lock lock(mtx_);
- notifier_.wait_for(lock,
std::chrono::seconds(config::recycle_interval_seconds),
+ notifier_.wait_for(lock,
std::chrono::seconds(config::scan_instances_interval_seconds),
[&]() { return stopped(); });
}
}
diff --git a/cloud/src/recycler/snapshot_data_migrator.cpp
b/cloud/src/recycler/snapshot_data_migrator.cpp
index e51bdc52478..e844dfbde5e 100644
--- a/cloud/src/recycler/snapshot_data_migrator.cpp
+++ b/cloud/src/recycler/snapshot_data_migrator.cpp
@@ -124,11 +124,6 @@ void SnapshotDataMigrator::scan_instance_loop() {
while (!stopped()) {
std::vector<InstanceInfoPB> instances;
get_all_instances(txn_kv_.get(), instances);
- LOG(INFO) << "Snapshot data migrator get instances: " << [&instances] {
- std::stringstream ss;
- for (auto& i : instances) ss << ' ' << i.instance_id();
- return ss.str();
- }();
if (!instances.empty()) {
// enqueue instances
std::lock_guard lock(mtx_);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
