From 6bb53f536a71cc65fb0961449c395a1c919c48d2 Mon Sep 17 00:00:00 2001 From: Yixuan Wang Date: Fri, 29 May 2026 11:24:57 +0800 Subject: [PATCH] [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 0c8645275a1754..be95c1781db109 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 9526b17200f3ac..c0d8dd8504d0e9 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 {