[INLONG-9925][Sort] Add if statement to solve continuously printing l…

…ogs (#9961)
apache · Apr 11, 2024 · bf8d1f7 · bf8d1f7
1 parent 3d47169
commit bf8d1f7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/...ors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java b/...ors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java
@@ -355,8 +355,11 @@ public void initializeState(FunctionInitializationContext context) throws Except
 
     @Override
     public synchronized void flush() throws IOException {
+        // when batch count > 0, execute flush operation
+        if (batchCount == 0) {
+            return;
+        }
         checkFlushException();
-
         for (int i = 0; i <= executionOptions.getMaxRetries(); i++) {
             try {
                 attemptFlush();

diff --git a/...dbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java b/...dbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java
@@ -608,6 +608,10 @@ public void initializeState(FunctionInitializationContext context) throws Except
 
     @Override
     public synchronized void flush() throws IOException {
+        // when batch count > 0, execute flush operation
+        if (batchCount == 0) {
+            return;
+        }
         checkFlushException();
         attemptFlush();
         batchCount = 0;