This is an automated email from the ASF dual-hosted git repository. jingzhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6bab695 [FLINK-25468] Copy SST files if they cannot be hard linked in RocksDBHandle.restoreInstanceDirectoryFromPath add 9fce1be [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner (#17684) No new revisions were added by this update. Summary of changes: .../exec/batch/BatchExecWindowTableFunction.java | 11 + .../exec/common/CommonExecWindowTableFunction.java | 8 +- .../exec/stream/StreamExecWindowTableFunction.java | 36 -- .../stream/SimplifyWindowTableFunctionRules.java | 348 ---------------- .../plan/utils/WindowTableFunctionUtil.java | 19 +- .../stream/StreamPhysicalWindowTableFunction.scala | 24 +- .../planner/plan/rules/FlinkStreamRuleSets.scala | 9 - .../ExpandWindowTableFunctionTransposeRule.scala | 3 +- .../StreamPhysicalWindowTableFunctionRule.scala | 3 +- .../stream/WindowTableFunctionJsonPlanTest.java | 44 ++ ...ase.java => WindowTableFunctionJsonITCase.java} | 17 +- .../nodes/exec/operator/StreamOperatorNameTest.xml | 28 +- .../testFollowedByWindowDeduplicate.out | 3 +- .../testFollowedByWindowJoin.out | 6 +- .../testFollowedByWindowRank.out | 3 +- .../testIndividualWindowTVF.out} | 264 ++++++------ .../testIndividualWindowTVFProcessingTime.out} | 215 +++++----- .../plan/stream/sql/WindowDeduplicateTest.xml | 14 +- .../planner/plan/stream/sql/WindowRankTest.xml | 14 +- .../plan/stream/sql/WindowTableFunctionTest.xml | 56 +++ .../plan/stream/sql/join/WindowJoinTest.xml | 52 +-- .../plan/metadata/FlinkRelMdHandlerTestBase.scala | 3 +- .../plan/stream/sql/WindowTableFunctionTest.scala | 44 +- .../harness/WindowTableFunctionHarnessTest.scala | 461 +++++++++++++++++++++ .../stream/sql/WindowTableFunctionITCase.scala | 379 +++++++++++++++++ 25 files changed, 1299 insertions(+), 765 deletions(-) delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/SimplifyWindowTableFunctionRules.java copy flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/{WindowDeduplicateJsonITCase.java => WindowTableFunctionJsonITCase.java} (82%) copy flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindow.out => WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVF.out} (73%) copy flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out => WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVFProcessingTime.out} (79%) create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/WindowTableFunctionHarnessTest.scala create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowTableFunctionITCase.scala