Skip to content

Commit c0f0d2d

Browse files
branch-4.1: [fix](recycler) Reduce recycle_job_lease_expired_ms for SnapshotDataMigrator #63388 (#63881)
Cherry-picked from #63388 Co-authored-by: Yixuan Wang <wangyixuan@selectdb.com>
1 parent 8106fbd commit c0f0d2d

2 files changed

Lines changed: 4 additions & 6 deletions

File tree

cloud/src/recycler/snapshot_chain_compactor.cpp

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -99,9 +99,8 @@ void SnapshotChainCompactor::compaction_loop() {
9999
}
100100

101101
std::string job_key = job_snapshot_chain_compactor_key(instance.instance_id());
102-
int ret =
103-
prepare_instance_recycle_job(txn_kv_.get(), job_key, instance.instance_id(),
104-
ip_port_, config::recycle_job_lease_expired_ms * 1000);
102+
int ret = prepare_instance_recycle_job(txn_kv_.get(), job_key, instance.instance_id(),
103+
ip_port_, config::recycle_job_lease_expired_ms);
105104
if (ret != 0) { // Prepare failed
106105
continue;
107106
} else {

cloud/src/recycler/snapshot_data_migrator.cpp

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -100,9 +100,8 @@ void SnapshotDataMigrator::migration_loop() {
100100
}
101101

102102
std::string job_key = job_snapshot_data_migrator_key(instance.instance_id());
103-
int ret =
104-
prepare_instance_recycle_job(txn_kv_.get(), job_key, instance.instance_id(),
105-
ip_port_, config::recycle_job_lease_expired_ms * 1000);
103+
int ret = prepare_instance_recycle_job(txn_kv_.get(), job_key, instance.instance_id(),
104+
ip_port_, config::recycle_job_lease_expired_ms);
106105
if (ret != 0) { // Prepare failed
107106
continue;
108107
} else {

0 commit comments

Comments
 (0)