[Improve] [Connector-V2] Throw StarRocks Serialize Error To Client (#4484)

Hisoka-X · web-flow · commit e2c107323b98 · 2023-04-11T18:20:09.000+08:00
* [Improve] [Connector-V2] Throw StarRocks Serialize Error To Client

* [Improve] [Connector-V2] Throw StarRocks Serialize Error To Client

* [Improve] [Connector-V2] Throw StarRocks Serialize Error To Client
diff --git a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java
@@ -60,8 +60,10 @@ public void write(SeaTunnelRow element) throws IOException {
         try {
             record = serializer.serialize(element);
         } catch (Exception e) {
-            log.error("serialize failed. Row={}", element);
-            throw e;
+            throw new StarRocksConnectorException(
+                    CommonErrorCode.WRITER_OPERATION_FAILED,
+                    "serialize failed. Row={" + element + "}",
+                    e);
         }
         manager.write(record);
     }

Original file line number	Diff line number	Diff line change
`@@ -60,8 +60,10 @@ public void write(SeaTunnelRow element) throws IOException {`
`60`	`60`	`try {`
`61`	`61`	`record = serializer.serialize(element);`
`62`	`62`	`} catch (Exception e) {`
`63`		`- log.error("serialize failed. Row={}", element);`
`64`		`- throw e;`
	`63`	`+ throw new StarRocksConnectorException(`
	`64`	`+ CommonErrorCode.WRITER_OPERATION_FAILED,`
	`65`	`+ "serialize failed. Row={" + element + "}",`
	`66`	`+ e);`
`65`	`67`	`}`
`66`	`68`	`manager.write(record);`
`67`	`69`	`}`