remove sleep

JNSimba · Aug 12, 2024 · 526d8ba · 526d8ba
1 parent be6f3af
commit 526d8ba
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/...doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java b/...doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java
@@ -425,11 +425,6 @@ public void run() {
 
         /** execute stream load. */
         public void load(String label, BatchRecordBuffer buffer) throws IOException {
-            try {
-                Thread.sleep(10000);
-            } catch (InterruptedException e) {
-                throw new RuntimeException(e);
-            }
             if (enableGroupCommit) {
                 label = null;
             }