[ISSUE #2347]🐛Fix PopBufferMergeService run too faster

mxsm · Jan 20, 2025 · 4dfef4f · 4dfef4f
1 parent 175be72
commit 4dfef4f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs b/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs
@@ -475,7 +475,7 @@ impl<MS: MessageStore> PopBufferMergeService<MS> {
                         if this.scan_times % this.count_of_second30 == 0 {
                             this.mut_from_ref().scan_garbage();
                         }
-                        tokio::time::sleep(tokio::time::Duration::from_millis(this.interval)).await;
+                        tokio::time::sleep(tokio::time::Duration::from_millis(interval)).await;
                         if !this.serving.load(Ordering::Acquire) && this.buffer.is_empty()  && this.get_offset_total_size() == 0 {
                             this.serving.store(true,Ordering::Release);
                         }