From 7c1de4645a2f8e7fa9af5f7ec5541be35a5957da Mon Sep 17 00:00:00 2001 From: ClownXC Date: Wed, 18 Dec 2024 08:15:06 +0800 Subject: [PATCH] exception --- .../apache/seatunnel/connectors/doris/rest/RestService.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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()); } }