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

Posted to commits@flink.apache.org by ja...@apache.org on 2021/06/24 09:23:15 UTC

[flink] branch master updated (2da9760 -> 6defc99)

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

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


    from 2da9760  [FLINK-23087] Make AddressResolution a top-level class
     add 6defc99  [FLINK-23025][upsert-kafka] Fix upsert-kafka produce duplicates when enable object reuse

No new revisions were added by this update.

Summary of changes:
 .../kafka/table/BufferedUpsertSinkFunction.java    |  4 +-
 .../table/BufferedUpsertSinkFunctionTest.java      | 76 ++++++++++++++++++----
 2 files changed, 66 insertions(+), 14 deletions(-)