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

Posted to commits@flink.apache.org by lz...@apache.org on 2022/02/09 15:27:47 UTC

[flink] branch master updated (a8ba755 -> bb1e504)

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

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


    from a8ba755  [FLINK-26039][table-runtime] Fix the incorrect value getter in map unnest table function
     add bb1e504  [FLINK-25696][datastream] Introduce metadataConsumer to InitContext in Sink

No new revisions were added by this update.

Summary of changes:
 .../flink/connector/kafka/sink/KafkaWriter.java    | 17 +++++++-
 .../connector/kafka/sink/KafkaWriterITCase.java    | 46 +++++++++++++++++++++-
 .../org/apache/flink/api/connector/sink2/Sink.java | 16 ++++++++
 3 files changed, 75 insertions(+), 4 deletions(-)