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(-)
