You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2021/01/22 11:50:10 UTC
[flink] branch master updated (5b477d3 -> c5bb490)

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 5b477d3  [FLINK-21011][table-planner-blink] Fix missed renaming for BatchExecJoinRuleBase, BatchExecNestedLoopJoinRuleBase and BatchExecSingleRowJoinRule
     add c5bb490  [FLINK-17868][table-planner-blink] Fix proctime in DDL can not work in batch mode

No new revisions were added by this update.

Summary of changes:
 .../plan/nodes/exec/stream/StreamExecCalc.java     |  10 +-
 .../nodes/exec/stream/StreamExecCorrelate.java     |   4 +-
 .../exec/stream/StreamExecDataStreamScan.java      |   4 +-
 .../stream/StreamExecLegacyTableSourceScan.java    |   4 +-
 .../BatchCommonSubGraphBasedOptimizer.scala        |   5 +
 .../plan/optimize/program/FlinkBatchProgram.scala  |   4 +
 .../optimize/program/FlinkOptimizeContext.scala    |  11 ++
 .../program/FlinkRelTimeIndicatorProgram.scala     |   6 +-
 .../optimize/program/StreamOptimizeContext.scala   |  11 --
 .../logical/BatchLogicalWindowAggregateRule.scala  |  11 +-
 .../table/planner/plan/batch/sql/TableScanTest.xml |  17 ++++
 .../planner/plan/batch/sql/TableSourceTest.xml     |  17 ++++
 .../planner/plan/batch/sql/join/LookupJoinTest.xml |  74 ++++++++------
 .../planner/plan/batch/sql/TableScanTest.scala     |  20 ++++
 .../planner/plan/batch/sql/TableSourceTest.scala   |   5 +
 .../runtime/batch/sql/TableScanITCase.scala        |  10 +-
 .../runtime/batch/sql/TableSourceITCase.scala      |  15 +++
 .../operators/AbstractProcessStreamOperator.java   | 113 ---------------------
 .../runtime/operators/TableStreamOperator.java     |  92 ++++++++++++++++-
 .../over/BufferDataOverWindowOperatorTest.java     |   2 +
 .../over/NonBufferOverWindowOperatorTest.java      |   2 +
 21 files changed, 255 insertions(+), 182 deletions(-)
 delete mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java