This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 20bac4b3 [Improve](log) add print log for NoRouteToHostException (#454)
20bac4b3 is described below
commit 20bac4b3d473d5864e94e3bcb9e2324f5a0848d0
Author: wudi <[email protected]>
AuthorDate: Tue Aug 6 19:08:46 2024 +0800
[Improve](log) add print log for NoRouteToHostException (#454)
---
.../java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
index 060bccb5..44ff573e 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
@@ -43,6 +43,7 @@ import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.Serializable;
+import java.net.NoRouteToHostException;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
@@ -287,6 +288,10 @@ public class DorisStreamLoad implements Serializable {
Preconditions.checkState(pendingLoadFuture != null);
try {
return handlePreCommitResponse(pendingLoadFuture.get());
+ } catch (NoRouteToHostException nex) {
+ LOG.error("Failed to connect, cause ", nex);
+ throw new DorisRuntimeException(
+ "No Route to Host to " + hostPort + ", exception: " + nex);
} catch (Exception e) {
throw new DorisRuntimeException(e);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
