exception

TongchengOpenSource · Dec 18, 2024 · 7c1de46 · 7c1de46
1 parent 8be7032
commit 7c1de46
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java b/...connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java
@@ -302,11 +302,15 @@ public static List<PartitionDefinition> 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());
             }
         }