code style

JNSimba · Aug 5, 2024 · 7cae6a2 · 7cae6a2
1 parent 1f35517
commit 7cae6a2
Showing 1 changed file with 3 additions and 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
@@ -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);
         }