(flink) branch master updated: [FLINK-31472][Connectors/Base] Update AsyncSink throttling test to use concurrent mailbox

[snuyanzin]

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

snuyanzin 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 6f6ab1ea352 [FLINK-31472][Connectors/Base] Update AsyncSink throttling 
test to use concurrent mailbox
6f6ab1ea352 is described below

commit 6f6ab1ea3527d96d57739eb4202bccd3c73c6458
Author: Ahmed Hamdy <ahmed.ha...@ververica.com>
AuthorDate: Wed Dec 20 11:18:40 2023 +0000

    [FLINK-31472][Connectors/Base] Update AsyncSink throttling test to use 
concurrent mailbox
---
 .../flink/connector/base/sink/writer/AsyncSinkWriterThrottlingTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterThrottlingTest.java
 
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterThrottlingTest.java
index 639cafe6d05..37a9768d2f2 100644
--- 
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterThrottlingTest.java
+++ 
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterThrottlingTest.java
@@ -45,7 +45,7 @@ public class AsyncSinkWriterThrottlingTest {
         int numberOfBatchesToSend = 1000;
         Queue<String> testRequests = getTestRequestsBuffer();
 
-        TestSinkInitContext context = new TestSinkInitContext();
+        TestSinkInitContext context = new 
TestSinkInitContextAnyThreadMailbox();
         TestProcessingTimeService tpts = 
context.getTestProcessingTimeService();
 
         ThrottlingWriter writer =