[Improve] [Connector-V2] Improve StarRocks Serialize Error Message (a…

…pache#4458)
ic4y · Apr 9, 2023 · d805f4b · d805f4b
1 parent 014f299
commit d805f4b
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...in/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java b/...in/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java
@@ -56,7 +56,13 @@ public StarRocksSinkWriter(SinkConfig sinkConfig, SeaTunnelRowType seaTunnelRowT
 
     @Override
     public void write(SeaTunnelRow element) throws IOException {
-        String record = serializer.serialize(element);
+        String record;
+        try {
+            record = serializer.serialize(element);
+        } catch (Exception e) {
+            log.error("serialize failed. Row={}", element);
+            throw e;
+        }
         manager.write(record);
     }