Replace error! with bail! in GlobalBarrierManagerContext for ea…

…rly termination on fail

Signed-off-by: Shanicky Chen <[email protected]>

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;
@@ -29,7 +30,7 @@ use risingwave_pb::stream_plan::{AddMutation, StreamActor};
 use thiserror_ext::AsReport;
 use tokio::time::Instant;
 use tokio_retry::strategy::{jitter, ExponentialBackoff};
-use tracing::{debug, error, info, warn, Instrument};
+use tracing::{debug, info, warn, Instrument};
 
 use super::{CheckpointControl, TracedEpoch};
 use crate::barrier::info::{InflightGraphInfo, InflightSubscriptionInfo};
@@ -541,7 +542,7 @@ impl GlobalBarrierManagerContext {
                 info!("integrity check passed");
             }
             Err(_) => {
-                error!("integrity check failed");
+                bail!("integrity check failed");
             }
         }