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

Posted to commits@flink.apache.org by tz...@apache.org on 2023/03/31 19:26:37 UTC

[flink] branch release-1.16 updated (701fccf4556 -> e8507e2addb)

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

tzulitai pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 701fccf4556 [FLINK-31683][docs-zh] Update the outdated Chinese filesystem connector docs
     add e8507e2addb [FLINK-31305] fix error propagation bug in WriterCallback and use TestSinkInitContext general purpose sink testing tool

No new revisions were added by this update.

Summary of changes:
 flink-connectors/flink-connector-kafka/pom.xml     |   8 +
 .../flink/connector/kafka/sink/KafkaWriter.java    |  23 +--
 .../connector/kafka/sink/KafkaWriterITCase.java    | 190 +++++++++++++++------
 3 files changed, 149 insertions(+), 72 deletions(-)