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 9a5a6c245..495a888a6 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 @@ -282,9 +282,10 @@ public RespContent stopLoad() throws IOException { Preconditions.checkState(pendingLoadFuture != null); try { return handlePreCommitResponse(pendingLoadFuture.get()); - } catch (NoRouteToHostException nex){ + } catch (NoRouteToHostException nex) { LOG.error("Failed to connect, cause ", nex); - throw new DorisRuntimeException("No Route to Host to " + hostPort + ", exception: " + nex); + throw new DorisRuntimeException( + "No Route to Host to " + hostPort + ", exception: " + nex); } catch (Exception e) { throw new DorisRuntimeException(e); }