minor fix

risingwavelabs · Feb 19, 2024 · 1cf2e1c · 1cf2e1c
1 parent 936be26
commit 1cf2e1c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/compute/src/rpc/service/stream_service.rs b/src/compute/src/rpc/service/stream_service.rs
@@ -173,7 +173,9 @@ impl StreamService for StreamServiceImpl {
         {
             Ok(result) => result,
             Err(e) => {
-                return Err(self.try_get_root_actor_failure().await.unwrap_or(e).into());
+                let err = self.try_get_root_actor_failure().await.unwrap_or(e);
+                tracing::error!(error = %err.as_report(), "failed to collect barrier");
+                return Err(err.into());
             }
         };