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

Posted to commits@flink.apache.org by tw...@apache.org on 2021/09/30 11:50:12 UTC

[flink] branch release-1.13 updated (5027c73 -> b0bf668)

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

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


    from 5027c73  [FLINK-23895][table] Upsert materializer is not inserted for all sink providers
     add fa16e70  [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible
     add b0bf668  [FLINK-24130][python] Fix RowDataSerializerTest after FLINK-24054

No new revisions were added by this update.

Summary of changes:
 .../runtime/stream/sql/DataStreamJavaITCase.java   |  8 +--
 .../operators/sink/SinkUpsertMaterializer.java     | 71 ++++++++++++----------
 .../operators/sink/SinkUpsertMaterializerTest.java | 46 ++++++++------
 .../table/runtime/util/StreamRecordUtils.java      | 16 ++---
 4 files changed, 79 insertions(+), 62 deletions(-)