[FLINK-27756] Setting batches to one and extending sending margin in …

…checkLoggedSendTimesAreWithinBounds test.
nicusX · Jun 13, 2022 · ceb285e · ceb285e
1 parent a70e704
commit ceb285e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...r-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java b/...r-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java
@@ -95,16 +95,16 @@ public void checkLoggedSendTimesAreWithinBounds() throws IOException, Interrupte
         AsyncSinkWriterImpl sink =
                 new AsyncSinkWriterImplBuilder()
                         .context(sinkInitContext)
-                        .maxBatchSize(2)
+                        .maxBatchSize(4)
                         .delay(100)
                         .build();
         for (int i = 0; i < 4; i++) {
             sink.write(String.valueOf(i));
         }
-
+        sink.flush(true);
         assertThat(sinkInitContext.getCurrentSendTimeGauge().get().getValue())
                 .isGreaterThanOrEqualTo(99);
-        assertThat(sinkInitContext.getCurrentSendTimeGauge().get().getValue()).isLessThan(110);
+        assertThat(sinkInitContext.getCurrentSendTimeGauge().get().getValue()).isLessThan(120);
     }
 
     @Test