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 69671a6 [FLINK-20697][docs] Fix the data type of 'lookup.cache.ttl'
in JDBC page
add 9e4da23 [FLINK-20623][table-planner-blink] Introduce
StreamPhysicalWatermarkAssigner, and make StreamExecWatermarkAssigner only
extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../exec/stream/StreamExecWatermarkAssigner.java | 89 ++++++++++++++++++++++
...arkAssignerChangelogNormalizeTransposeRule.java | 10 +--
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 2 +-
...scala => StreamPhysicalWatermarkAssigner.scala} | 63 ++++-----------
.../FlinkChangelogModeInferenceProgram.scala | 4 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +-
.../stream/MiniBatchIntervalInferRule.scala | 8 +-
...a => StreamPhysicalWatermarkAssignerRule.scala} | 14 ++--
8 files changed, 125 insertions(+), 67 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecWatermarkAssigner.java
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecWatermarkAssigner.scala
=> StreamPhysicalWatermarkAssigner.scala} (50%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecWatermarkAssignerRule.scala
=> StreamPhysicalWatermarkAssignerRule.scala} (86%)
