lianghuan-xatu commented on code in PR #3564:
URL:
https://github.com/apache/incubator-seatunnel/pull/3564#discussion_r1032524403
##########
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSource.java:
##########
@@ -158,7 +161,8 @@ private PartitionParameter
initPartitionParameter(KuduClient kuduClient, String
}
}
} catch (KuduException e) {
- throw new RuntimeException("Failed to generate upper and lower
limits for each partition", e);
+ log.error("Failed to generate upper and lower limits for each
partition", ExceptionUtils.getMessage(e));
Review Comment:
I have fixed it!Thx
##########
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSource.java:
##########
@@ -121,7 +124,7 @@ public void prepare(Config config) {
SeaTunnelRowType seaTunnelRowType =
getSeaTunnelRowType(kuduClient.openTable(tableName).getSchema().getColumns());
rowTypeInfo = seaTunnelRowType;
} catch (KuduException e) {
- throw new RuntimeException("Parameters in the preparation phase
fail to be generated", e);
+ throw new
KuduConnectorException(KuduConnectorErrorCode.GENERATE_KUDU_PARAMETERS_FAILED,
e);
Review Comment:
I have fixed it! Thx
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
