update

JNSimba · Aug 7, 2024 · c449f7c · c449f7c
1 parent 7ddb0ba
commit c449f7c
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
@@ -312,11 +312,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;
             }