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 e46ee85 [FLINK-19852][task] Reuse TempBarrier memory between
iterations
add bd5bc76 [hotfix][docs] Update YARN config docs
add 62657de [hotfix][table-planner-blink] Enable idle state cleanup for
ChangelogNormalize operator
add 6e1b842 [FLINK-19795][table-blink] Fix Flink SQL throws exception
when changelog source contains duplicate change events
No new revisions were added by this update.
Summary of changes:
.../generated/execution_config_configuration.html | 6 +
.../generated/yarn_config_configuration.html | 12 +-
docs/dev/table/connectors/formats/canal.md | 11 ++
docs/dev/table/connectors/formats/canal.zh.md | 11 ++
docs/dev/table/connectors/formats/debezium.md | 8 +
docs/dev/table/connectors/formats/debezium.zh.md | 8 +
.../table/api/config/ExecutionConfigOptions.java | 27 +++
.../PushProjectIntoTableSourceScanRule.java | 24 +--
.../planner/plan/schema/CatalogSourceTable.java | 3 +-
.../table/planner/sources/DynamicSourceUtils.java | 61 +++++-
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 8 +
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 6 +
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 7 +
.../stream/StreamExecChangelogNormalize.scala | 7 +-
...pand.scala => StreamExecDropUpdateBefore.scala} | 71 +++----
.../FlinkChangelogModeInferenceProgram.scala | 10 +-
.../stream/StreamExecTableSourceScanRule.scala | 31 ++-
.../physical/stream/ChangelogModeInferenceTest.xml | 7 +-
.../planner/plan/stream/sql/TableScanTest.xml | 141 +++++++++----
.../metadata/FlinkRelMdColumnUniquenessTest.scala | 9 +
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 8 +
.../FlinkRelMdModifiedMonotonicityTest.scala | 7 +
.../plan/metadata/FlinkRelMdUniqueKeysTest.scala | 5 +
.../stream/ChangelogModeInferenceTest.scala | 1 +
.../planner/plan/stream/sql/TableScanTest.scala | 54 +++++
.../runtime/stream/sql/ChangelogSourceITCase.scala | 135 ++++++++++---
.../runtime/stream/sql/TemporalJoinITCase.scala | 217 ++++++++-------------
.../misc/DropUpdateBeforeFunction.java} | 26 ++-
28 files changed, 605 insertions(+), 316 deletions(-)
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecExpand.scala
=> StreamExecDropUpdateBefore.scala} (60%)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/{generated/WatermarkGenerator.java
=> operators/misc/DropUpdateBeforeFunction.java} (59%)
