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 4dde0ca [FLINK-24771][jdbc][tests] Bump test dependencies
mariadb-java-client to 2.7.4 and mysql-connector-java to 8.0.27
add 1a43934 [FLINK-24227][connectors] Improved AsyncSink base by adding a
builder, adding more commonly used metrics, more java docs around certain
implementation tips, and a fatalException callback. Using a builder to build
AsyncSinkWriterTest mocks, added test to test timing, fixed
setCurrentSendTimeGauge so that no race conditions may occur, changed protected
fields to private and installed protected getters. Removed MetricGroupMocks and
using existing mocks, made build() public [...]
No new revisions were added by this update.
Summary of changes:
.../flink/connector/base/sink/AsyncSinkBase.java | 47 +++
.../connector/base/sink/AsyncSinkBaseBuilder.java | 140 ++++++++
.../base/sink/writer/AsyncSinkWriter.java | 91 ++++-
.../src/main/resources/log4j2.properties | 2 +-
.../connector/base/sink/ArrayListAsyncSink.java | 36 +-
.../base/sink/writer/AsyncSinkWriterTest.java | 372 ++++++++++++++++++---
6 files changed, 619 insertions(+), 69 deletions(-)
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBaseBuilder.java
