From 1cf2e1cd73b61a24ad543d6b01447bade86a9d59 Mon Sep 17 00:00:00 2001 From: zwang28 <84491488@qq.com> Date: Mon, 19 Feb 2024 22:21:38 +0800 Subject: [PATCH] minor fix --- src/compute/src/rpc/service/stream_service.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/compute/src/rpc/service/stream_service.rs b/src/compute/src/rpc/service/stream_service.rs index d6452703fe804..209ff93b5ec56 100644 --- 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()); } };