try to fix distributed pipeline error mechanism bug

JackTan25 · Jul 12, 2023 · 19ab4ff · 19ab4ff
1 parent ee97a48
commit 19ab4ff
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/src/query/service/src/api/rpc/exchange/statistics_sender.rs b/src/query/service/src/api/rpc/exchange/statistics_sender.rs
@@ -101,7 +101,6 @@ impl StatisticsSender {
     }
 
     pub fn shutdown(&mut self, error: Option<ErrorCode>) {
-        self.shutdown_flag.store(true, Ordering::Release);
         let shutdown_flag_sender = self.shutdown_flag_sender.clone();
 
         let join_handle = self.join_handle.take();