This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9055279 [hotfix] [runtime] Remove unused method
ResourceManager#getNumberRequiredTaskManagers()
new 493bf3d [FLINK-25792][connectors] Only flushing the async sink base
if it is possible to do it in a non blocking fashion or if the buffer is full.
Added test to verify blocking behaviour when number of max in flight requests
has been reached. Bubble up interrupted exception if raised while waiting to
clear an in flight request in the async sink.
new e16ef6b [FLINK-25792][connectors] Changed repeated yielding in write
to non blocking flush after complete request, changed tests so that the mailbox
thread is cleared before each write().
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../sink/KinesisFirehoseSinkWriterTest.java | 14 +-
.../base/sink/writer/AsyncSinkWriter.java | 54 ++++--
.../base/sink/writer/AsyncSinkWriterTest.java | 198 ++++++++++++++-------
.../base/sink/writer/TestSinkInitContext.java | 51 +++---
.../TestSinkInitContextAnyThreadMailbox.java | 54 ++++++
5 files changed, 269 insertions(+), 102 deletions(-)
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/TestSinkInitContextAnyThreadMailbox.java
