Replace error! with bail! in GlobalBarrierManagerContext for ea…

…rly termination on fail Signed-off-by: Shanicky Chen <[email protected]>
risingwavelabs · Oct 24, 2024 · 3b99734 · 3b99734
1 parent f637d0f
commit 3b99734
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/meta/src/barrier/recovery.rs b/src/meta/src/barrier/recovery.rs
@@ -17,6 +17,7 @@ use std::time::Duration;
 
 use anyhow::{anyhow, Context};
 use itertools::Itertools;
+use risingwave_common::bail;
 use risingwave_common::catalog::TableId;
 use risingwave_common::config::DefaultParallelism;
 use risingwave_common::hash::WorkerSlotId;
@@ -541,7 +542,7 @@ impl GlobalBarrierManagerContext {
                 info!("integrity check passed");
             }
             Err(_) => {
-                error!("integrity check failed");
+                bail!("integrity check failed");
             }
         }