fix(storage): fix expired timeout sec (#15194)

risingwavelabs · Feb 23, 2024 · e223b9f · e223b9f
1 parent 34bb7e3
commit e223b9f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/meta/node/src/lib.rs b/src/meta/node/src/lib.rs
@@ -254,7 +254,7 @@ pub fn start(opts: MetaNodeOpts) -> Pin<Box<dyn Future<Output = ()> + Send>> {
 
         const MIN_TIMEOUT_INTERVAL_SEC: u64 = 20;
         let compaction_task_max_progress_interval_secs = {
-            config
+            (config
                 .storage
                 .object_store
                 .object_store_read_timeout_ms
@@ -271,7 +271,8 @@ pub fn start(opts: MetaNodeOpts) -> Pin<Box<dyn Future<Output = ()> + Send>> {
                         .object_store
                         .object_store_streaming_upload_timeout_ms,
                 )
-                .max(config.meta.compaction_task_max_progress_interval_secs)
+                .max(config.meta.compaction_task_max_progress_interval_secs * 1000))
+                / 1000
         } + MIN_TIMEOUT_INTERVAL_SEC;
 
         let (mut join_handle, leader_lost_handle, shutdown_send) = rpc_serve(