This is an automated email from the ASF dual-hosted git repository.
zhouyao2023 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new ebc9ee3915 [improve]improve FE node failover logging for better
observability (#9657)
ebc9ee3915 is described below
commit ebc9ee3915fd483f4a61c253f80856d7a7bd60b1
Author: zhenyue-xu <[email protected]>
AuthorDate: Mon Aug 4 19:37:21 2025 +0800
[improve]improve FE node failover logging for better observability (#9657)
Co-authored-by: Jia Fan <[email protected]>
---
.../apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java
index a2b4f3da99..7d1637e381 100644
---
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java
+++
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java
@@ -120,6 +120,7 @@ public class DorisSinkWriter
for (int i = 0; i < feNodesNum; i++) {
try {
+ log.info("Trying FE node {} for stream load.",
feNodes.get(i));
this.dorisStreamLoad =
new DorisStreamLoad(
feNodes.get(i),
@@ -133,6 +134,7 @@ public class DorisSinkWriter
break;
} catch (Exception e) {
if (i == feNodesNum - 1) {
+ log.error("All {} FE nodes failed, no more nodes to try",
feNodesNum);
throw new DorisConnectorException(
DorisConnectorErrorCode.STREAM_LOAD_FAILED, e);
}
