(inlong) branch master updated: [INLONG-9925][Sort] Add if statement to solve continuously printing logs (#9961)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new bf8d1f7f40 [INLONG-9925][Sort] Add if statement to solve continuously 
printing logs (#9961)
bf8d1f7f40 is described below

commit bf8d1f7f40569ddc3b319bd69d72a0ca2c6a3700
Author: XiaoYou201 <58425449+xiaoyou...@users.noreply.github.com>
AuthorDate: Thu Apr 11 21:37:06 2024 +0800

    [INLONG-9925][Sort] Add if statement to solve continuously printing logs 
(#9961)
---
 .../apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java   | 5 ++++-
 .../inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java     | 4 ++++
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java
 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java
index 7b3b1db4f1..dc96bb6ae3 100644
--- 
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java
+++ 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java
@@ -355,8 +355,11 @@ public class JdbcBatchingOutputFormat<In, JdbcIn, JdbcExec 
extends JdbcBatchStat
 
     @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/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java
 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java
index 467522ee22..47fe13aa90 100644
--- 
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java
+++ 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java
@@ -608,6 +608,10 @@ public class JdbcMultiBatchingOutputFormat<In, JdbcIn, 
JdbcExec extends JdbcBatc
 
     @Override
     public synchronized void flush() throws IOException {
+        // when batch count > 0, execute flush operation
+        if (batchCount == 0) {
+            return;
+        }
         checkFlushException();
         attemptFlush();
         batchCount = 0;