TaoZex commented on code in PR #3593:
URL:
https://github.com/apache/incubator-seatunnel/pull/3593#discussion_r1034243774
##########
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java:
##########
@@ -165,12 +167,12 @@ private void checkLabelState(String host, String label)
throws IOException {
String queryLoadStateUrl = new
StringBuilder(host).append("/api/").append(sinkConfig.getDatabase()).append("/get_load_state?label=").append(label).toString();
Map<String, Object> result =
httpHelper.doHttpGet(queryLoadStateUrl, getLoadStateHttpHeader(label));
if (result == null) {
- throw new IOException(String.format("Failed to flush data
to StarRocks, Error " +
+ throw new
StarRocksConnectorException(CommonErrorCode.ILLEGAL_ARGUMENT,
String.format("Failed to flush data to StarRocks, Error " +
Review Comment:
You can use the prompts to know which error code to use.In this case, the
error code should be related to `flush data fail`.
--
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]
