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

Posted to commits@flink.apache.org by al...@apache.org on 2020/06/15 17:04:42 UTC

[flink] branch master updated (e01cab2 -> 889705c)

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

aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from e01cab2  [FLINK-18039] Ensure the source events are sent via the coordinator thread.
     add 36edd14  [minor] In FlinkKafkaInternalProducer add Javadoc to internal methods and clarify names
     add 216744a  [minor] In FlinkKafkaInternalProducer add Javadoc to internal enqueueNewPartitions()
     add 711f619  [FLINK-17327] Always use close() with zero timeout in exactly-once Kafka Producer
     add 889705c  [FLINK-15362] Bump Kafka connector to 2.4.1

No new revisions were added by this update.

Summary of changes:
 .../connectors/kafka/FlinkKafkaProducer011.java    |  7 +-
 flink-connectors/flink-connector-kafka/pom.xml     |  2 +-
 .../connectors/kafka/FlinkKafkaProducer.java       | 57 ++++++++++++----
 .../kafka/internal/FlinkKafkaInternalProducer.java | 79 +++++++++++++---------
 .../kafka/FlinkKafkaInternalProducerITCase.java    | 35 +++++++---
 .../src/main/resources/META-INF/NOTICE             |  2 +-
 flink-dist/src/main/resources/META-INF/NOTICE      |  2 +-
 .../tests/util/kafka/SQLClientKafkaITCase.java     |  2 +-
 .../tests/util/kafka/StreamingKafkaITCase.java     |  2 +-
 flink-end-to-end-tests/test-scripts/common.sh      |  1 +
 flink-runtime/pom.xml                              |  2 +-
 11 files changed, 126 insertions(+), 65 deletions(-)