diff --git a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java index 02be965ffba..cb2f33df931 100644 --- a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java +++ b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java @@ -302,11 +302,15 @@ public static List findPartitions( httpPost.setEntity(stringEntity); resStr = send(dorisSourceConfig, httpPost, logger); break; - } catch (DorisConnectorException e) { + } catch (Exception e) { if (i == feNodesNum - 1) { throw new DorisConnectorException( DorisConnectorErrorCode.REST_SERVICE_FAILED, e); } + log.error( + "Find partition error for feNode: {} with exception: {}", + feNodes.get(i), + e.getMessage()); } }