fix(error): fix sinkError and connector error (#18425) (#18441)

Co-authored-by: Xinhao Xu <[email protected]>
risingwavelabs · Sep 6, 2024 · 9cb0732 · 9cb0732
1 parent a9ed85a
commit 9cb0732
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/src/stream/src/executor/error.rs b/src/stream/src/executor/error.rs
@@ -67,7 +67,12 @@ pub enum ErrorKind {
     ),
 
     #[error("Sink error: sink_id={1}, error: {0}")]
-    SinkError(SinkError, u32),
+    SinkError(
+        #[source]
+        #[backtrace]
+        SinkError,
+        u32,
+    ),
 
     #[error(transparent)]
     RpcError(
@@ -90,7 +95,11 @@ pub enum ErrorKind {
     AlignBarrier(Box<Barrier>, Box<Barrier>),
 
     #[error("Connector error: {0}")]
-    ConnectorError(BoxedError),
+    ConnectorError(
+        #[source]
+        #[backtrace]
+        BoxedError,
+    ),
 
     #[error(transparent)]
     DmlError(