This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 74fd8b7 [FLINK-20322][table-planner-blink] Rename
union-all-as-breakpoint configuration and change the default value
add 4cc1da9 [FLINK-20314][table-planner] Add rule to remove empty
FlinkLogicalCalc
No new revisions were added by this update.
Summary of changes:
.../rules/logical/FlinkLogicalCalcRemoveRule.java} | 24 +++++-----
.../planner/plan/rules/FlinkStreamRuleSets.scala | 4 ++
.../plan/stream/sql/SourceWatermarkTest.xml | 18 ++++++++
.../plan/stream/sql/SourceWatermarkTest.scala | 46 ++++++++++---------
.../runtime/stream/sql/SourceWatermarkITCase.scala | 51 ++++++++++++++++++++++
5 files changed, 112 insertions(+), 31 deletions(-)
copy
flink-table/{flink-table-common/src/main/java/org/apache/flink/table/annotation/UnknownSerializer.java
=>
flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkLogicalCalcRemoveRule.java}
(58%)
