From 7cae6a260d3ed94a715faf4de8993b2624ead5b8 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Mon, 5 Aug 2024 14:59:32 +0800 Subject: [PATCH] code style --- .../org/apache/doris/flink/sink/writer/DorisStreamLoad.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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); }