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 bca8e47 [FLINK-19684][jdbc] Fix 'max-retries' option doesn't work
when set to zero
add 3c67cce [FLINK-19694][table-planner-blink] Support upsert
ChangelogMode for ScanTableSource in planner
add 92a2648 [FLINK-19694][table-planner-blink] Update MetadataHandlers
for the new introduced StreamExecUpsertMaterialize node
add 436a4c2 [FLINK-19694][table-runtime-blink] Support upsert
ChangelogMode for ScanTableSource in runtime
No new revisions were added by this update.
Summary of changes:
.../PushProjectIntoTableSourceScanRule.java | 50 +++-
.../table/planner/sources/DynamicSourceUtils.java | 21 +-
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 8 +
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 22 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 7 +
...te.scala => StreamExecChangelogNormalize.scala} | 101 +++----
.../physical/stream/StreamExecDeduplicate.scala | 22 +-
.../FlinkChangelogModeInferenceProgram.scala | 21 +-
.../stream/StreamExecTableSourceScanRule.scala | 48 +++-
.../flink/table/planner/plan/utils/ScanUtil.scala | 27 +-
.../planner/plan/stream/sql/TableScanTest.xml | 273 ++++++++++++++++---
.../plan/stream/sql/join/SemiAntiJoinTest.xml | 2 +-
.../planner/plan/batch/sql/TableScanTest.scala | 23 ++
.../metadata/FlinkRelMdColumnUniquenessTest.scala | 9 +
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 14 +-
.../FlinkRelMdModifiedMonotonicityTest.scala | 25 ++
.../plan/metadata/FlinkRelMdUniqueKeysTest.scala | 7 +-
.../planner/plan/stream/sql/TableScanTest.scala | 197 +++++++++++++-
.../runtime/stream/sql/ChangelogSourceITCase.scala | 297 +++++++++++++++++----
.../planner/runtime/stream/sql/JoinITCase.scala | 44 ---
.../table/planner/runtime/utils/TestData.scala | 18 ++
.../deduplicate/DeduplicateFunctionHelper.java | 56 +++-
.../DeduplicateKeepLastRowFunction.java | 15 +-
.../MiniBatchDeduplicateKeepLastRowFunction.java | 13 +-
.../DeduplicateKeepLastRowFunctionTest.java | 3 +-
...iniBatchDeduplicateKeepLastRowFunctionTest.java | 1 +
26 files changed, 1054 insertions(+), 270 deletions(-)
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecDeduplicate.scala
=> StreamExecChangelogNormalize.scala} (60%)
