fix comm

risingwavelabs · Nov 1, 2024 · 908e5c8 · 908e5c8
1 parent a9871cc
commit 908e5c8
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/connector/src/sink/starrocks.rs b/src/connector/src/sink/starrocks.rs
@@ -531,7 +531,15 @@ impl Drop for StarrocksSinkWriter {
     fn drop(&mut self) {
         if let Some(txn_label) = self.curr_txn_label.take() {
             let txn_client = self.txn_client.clone();
-            tokio::spawn(async move { txn_client.rollback(txn_label).await.ok() });
+            tokio::spawn(async move {
+                if let Err(e) = txn_client.rollback(txn_label.clone()).await {
+                    tracing::error!(
+                        "starrocks rollback transaction error: {:?}, txn label: {}",
+                        e,
+                        txn_label
+                    );
+                }
+            });
         }
     }
 }