This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 2d18ee4b2fe branch-4.1: [chore](cloud) adjust snapshot data migrator
and chain compactor scan interval to 1 minute #61622 (#61642)
2d18ee4b2fe is described below
commit 2d18ee4b2fe451e6892a7a7b0f8937d2401a3369
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Mar 24 15:36:18 2026 +0800
branch-4.1: [chore](cloud) adjust snapshot data migrator and chain
compactor scan interval to 1 minute #61622 (#61642)
Cherry-picked from #61622
Co-authored-by: walter <[email protected]>
---
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]
