diff --git a/main/src/clickhouse_utils.rs b/main/src/clickhouse_utils.rs index ab2207c..6df42bf 100644 --- a/main/src/clickhouse_utils.rs +++ b/main/src/clickhouse_utils.rs @@ -63,7 +63,7 @@ impl Writer { ) -> Result<()> { let state = Arc::new(Mutex::new(WriterState { notify: Vec::new() })); let map = Arc::new(map); - retry(ExponentialBackoff::default(), || async { + retry(ExponentialBackoff { max_elapsed_time: None, ..ExponentialBackoff::default() }, || async { Writer::go( self.cfg.clone(), client.clone(),