[flink] branch master updated (e6ef269 -> 3eef1cb)

[lz...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from e6ef269  [FLINK-22355][docs] Fix simple task manager memory model image
     add 3eef1cb  [FLINK-19606][table-planner] Introduce StreamExecWindowJoin and window join it cases

No new revisions were added by this update.

Summary of changes:
 ...reamExecJoin.java => StreamExecWindowJoin.java} |  117 +-
 .../physical/stream/StreamPhysicalWindowJoin.scala |   13 +-
 .../nodes/exec/stream/WindowJoinJsonPlanTest.java  |  112 ++
 .../stream/jsonplan/WindowJoinJsonITCase.java      |  130 +++
 .../testEventTimeTumbleWindow.out}                 | 1200 +++++++++++++-------
 .../runtime/stream/sql/WindowJoinITCase.scala      |  607 ++++++++++
 .../table/planner/runtime/utils/TestData.scala     |   41 +
 7 files changed, 1752 insertions(+), 468 deletions(-)
 copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{StreamExecJoin.java => StreamExecWindowJoin.java} (64%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowJoinJsonPlanTest.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/WindowJoinJsonITCase.java
 copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out => WindowJoinJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out} (55%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowJoinITCase.scala