You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by da...@apache.org on 2021/11/10 10:07:05 UTC

[flink] branch master updated (4dde0ca -> 1a43934)

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