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 9d449ff [FLINK-23041][webui] Renamed alignment_timeout to
aligned_checkpoint_timeout in WebUI
new e1117f0 [FLINK-23054][table] TemporalJoinRewrite should based on
upsert key
new 4642c1f [FLINK-23054][table] Rank update optimization should based on
upsert key
new 992340e [FLINK-23054][table] Join unique/pk optimization should based
on upsert key
new 5fdc01e [FLINK-23054][table] Add SinkUpsertMaterialize before upsert
sink to resolve change log disorder
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../generated/execution_config_configuration.html | 6 +
.../table/api/config/ExecutionConfigOptions.java | 32 +++++
.../plan/nodes/exec/batch/BatchExecSink.java | 2 +-
.../plan/nodes/exec/common/CommonExecSink.java | 51 +++++--
.../plan/nodes/exec/stream/StreamExecSink.java | 16 ++-
.../planner/plan/utils/RankProcessStrategy.java | 16 +--
.../nodes/physical/stream/StreamPhysicalJoin.scala | 28 ++--
.../nodes/physical/stream/StreamPhysicalSink.scala | 60 +++++++-
.../plan/rules/logical/CalcRankTransposeRule.scala | 8 +-
.../TemporalJoinRewriteWithUniqueKeyRule.scala | 12 +-
.../planner/plan/stream/sql/TableSinkTest.xml | 74 +++++++++-
.../planner/plan/stream/sql/join/JoinTest.xml | 43 ++++++
.../planner/plan/stream/sql/TableSinkTest.scala | 66 +++++++++
.../planner/plan/stream/sql/join/JoinTest.scala | 34 +++++
.../runtime/stream/sql/TableSinkITCase.scala | 157 +++++++++++++++++++++
.../operators/sink/SinkUpsertMaterializer.java | 151 ++++++++++++++++++++
.../operators/sink/SinkUpsertMaterializerTest.java | 127 +++++++++++++++++
17 files changed, 836 insertions(+), 47 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TableSinkITCase.scala
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkUpsertMaterializer.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/sink/SinkUpsertMaterializerTest.java
