This is an automated email from the ASF dual-hosted git repository.
gavinchou 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 1e8e91dbee1 [fix](recycler) Reduce recycle_job_lease_expired_ms for
SnapshotDataMigrator (#63388)
1e8e91dbee1 is described below
commit 1e8e91dbee17a06c3885b1ba174741b6c4eef0d9
Author: Yixuan Wang <[email protected]>
AuthorDate: Fri May 29 11:24:57 2026 +0800
[fix](recycler) Reduce recycle_job_lease_expired_ms for
SnapshotDataMigrator (#63388)
---
cloud/src/recycler/snapshot_chain_compactor.cpp | 5 ++---
cloud/src/recycler/snapshot_data_migrator.cpp | 5 ++---
2 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/cloud/src/recycler/snapshot_chain_compactor.cpp
b/cloud/src/recycler/snapshot_chain_compactor.cpp
index 0c8645275a1..be95c1781db 100644
--- a/cloud/src/recycler/snapshot_chain_compactor.cpp
+++ b/cloud/src/recycler/snapshot_chain_compactor.cpp
@@ -99,9 +99,8 @@ void SnapshotChainCompactor::compaction_loop() {
}
std::string job_key =
job_snapshot_chain_compactor_key(instance.instance_id());
- int ret =
- prepare_instance_recycle_job(txn_kv_.get(), job_key,
instance.instance_id(),
- ip_port_,
config::recycle_job_lease_expired_ms * 1000);
+ int ret = prepare_instance_recycle_job(txn_kv_.get(), job_key,
instance.instance_id(),
+ ip_port_,
config::recycle_job_lease_expired_ms);
if (ret != 0) { // Prepare failed
continue;
} else {
diff --git a/cloud/src/recycler/snapshot_data_migrator.cpp
b/cloud/src/recycler/snapshot_data_migrator.cpp
index 9526b17200f..c0d8dd8504d 100644
--- a/cloud/src/recycler/snapshot_data_migrator.cpp
+++ b/cloud/src/recycler/snapshot_data_migrator.cpp
@@ -100,9 +100,8 @@ void SnapshotDataMigrator::migration_loop() {
}
std::string job_key =
job_snapshot_data_migrator_key(instance.instance_id());
- int ret =
- prepare_instance_recycle_job(txn_kv_.get(), job_key,
instance.instance_id(),
- ip_port_,
config::recycle_job_lease_expired_ms * 1000);
+ int ret = prepare_instance_recycle_job(txn_kv_.get(), job_key,
instance.instance_id(),
+ ip_port_,
config::recycle_job_lease_expired_ms);
if (ret != 0) { // Prepare failed
continue;
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
