lower the max delay

risingwavelabs · Nov 20, 2024 · 59a7b72 · 59a7b72
1 parent da225d5
commit 59a7b72
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/stream/src/executor/backfill/cdc/cdc_backfill.rs b/src/stream/src/executor/backfill/cdc/cdc_backfill.rs
@@ -836,8 +836,7 @@ impl UpstreamBarriers {
 fn get_backoff_strategy() -> impl Iterator<Item = Duration> {
     const BASE_DELAY: Duration = Duration::from_secs(1);
     const BACKOFF_FACTOR: u64 = 2;
-    const MAX_DELAY: Duration = Duration::from_secs(180);
-
+    const MAX_DELAY: Duration = Duration::from_secs(8);
     ExponentialBackoff::from_millis(BASE_DELAY.as_millis() as u64)
         .factor(BACKOFF_FACTOR)
         .max_delay(MAX_DELAY)