[flink] branch master updated: [FLINK-27756] Setting batches to one and extending sending margin in checkLoggedSendTimesAreWithinBounds test.

[dannycranmer]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new ceb285ef5c0 [FLINK-27756] Setting batches to one and extending sending 
margin in checkLoggedSendTimesAreWithinBounds test.
ceb285ef5c0 is described below

commit ceb285ef5c0f2d501f2e29031e58ac52402c2a5c
Author: Ahmed Hamdy <vah...@amazon.com>
AuthorDate: Sun Jun 5 21:07:56 2022 +0100

    [FLINK-27756] Setting batches to one and extending sending margin in 
checkLoggedSendTimesAreWithinBounds test.
---
 .../flink/connector/base/sink/writer/AsyncSinkWriterTest.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java
 
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java
index ce18e1111a7..c8535bfcef1 100644
--- 
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java
+++ 
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java
@@ -95,16 +95,16 @@ public class AsyncSinkWriterTest {
         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