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 6d673ae [FLINK-24023][runtime-web] The names of metrics are
incomplete (#17117)
add 68a29f3 Revert "[FLINK-23544][table-planner] Window TVF Supports
session window in plan"
No new revisions were added by this update.
Summary of changes:
.../functions/sql/FlinkSqlOperatorTable.java | 1 -
.../functions/sql/SqlSessionTableFunction.java | 67 ------
.../functions/sql/SqlWindowTableFunction.java | 3 -
.../planner/plan/logical/SessionWindowSpec.java | 74 -------
.../table/planner/plan/logical/WindowSpec.java | 3 +-
.../exec/stream/StreamExecWindowTableFunction.java | 5 -
.../TwoStageOptimizedWindowAggregateRule.java | 7 -
.../StreamPhysicalLocalWindowAggregate.scala | 13 +-
.../stream/StreamPhysicalWindowAggregate.scala | 64 ++----
.../plan/rules/logical/SplitAggregateRule.scala | 10 +-
.../table/planner/plan/utils/WindowUtil.scala | 4 -
.../planner/plan/stream/sql/WindowRankTest.xml | 53 -----
.../plan/stream/sql/agg/WindowAggregateTest.xml | 236 ---------------------
.../plan/stream/sql/join/WindowJoinTest.xml | 139 ------------
.../planner/plan/stream/sql/WindowRankTest.scala | 79 +------
.../plan/stream/sql/agg/WindowAggregateTest.scala | 64 ------
.../plan/stream/sql/join/WindowJoinTest.scala | 106 ---------
.../runtime/stream/sql/WindowAggregateITCase.scala | 87 --------
.../window/WindowTableFunctionOperator.java | 3 -
19 files changed, 21 insertions(+), 997 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/SqlSessionTableFunction.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/logical/SessionWindowSpec.java
