This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 488d60a1d39 [FLINK-34066][table-planner] Fix LagFunction throw NPE
when input argument are not null (#24075)
add 36886541522 [FLINK-33958] Implement restore tests for IntervalJoin node
add 534df6490e0 [FLINK-33958] Remove IntervalJoin Json Plan & IT tests
No new revisions were added by this update.
Summary of changes:
.../exec/stream/IntervalJoinJsonPlanTest.java | 99 ---
.../nodes/exec/stream/IntervalJoinRestoreTest.java | 41 ++
.../exec/stream/IntervalJoinTestPrograms.java | 194 +++++
.../jsonplan/IntervalJoinJsonPlanITCase.java | 117 ---
.../testProcessingTimeInnerJoinWithOnClause.out | 784 ---------------------
.../plan/interval-join-event-time.json} | 257 +++----
.../interval-join-event-time/savepoint/_metadata | Bin 0 -> 19515 bytes
.../plan/interval-join-negative-interval.json} | 321 ++++-----
.../savepoint/_metadata | Bin 0 -> 9505 bytes
.../plan/interval-join-proc-time.json | 445 ++++++++++++
.../interval-join-proc-time/savepoint/_metadata | Bin 0 -> 19511 bytes
11 files changed, 920 insertions(+), 1338 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinRestoreTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinTestPrograms.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/IntervalJoinJsonPlanITCase.java
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testProcessingTimeInnerJoinWithOnClause.out
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testRowTimeInnerJoinWithOnClause.out
=>
restore-tests/stream-exec-interval-join_1/interval-join-event-time/plan/interval-join-event-time.json}
(66%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-interval-join_1/interval-join-event-time/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testRowTimeInnerJoinWithOnClause.out
=>
restore-tests/stream-exec-interval-join_1/interval-join-negative-interval/plan/interval-join-negative-interval.json}
(62%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-interval-join_1/interval-join-negative-interval/savepoint/_metadata
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-interval-join_1/interval-join-proc-time/plan/interval-join-proc-time.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-interval-join_1/interval-join-proc-time/savepoint/_metadata
