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 1668a072769 [FLINK-34933][test] Fixes
JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored
add b3334d1527a [FLINK-33805] Implement restore tests for OverAggregate
node
add bf60c881359 [FLINK-33805] Deleting OverAggregateJsonPlanTest.java and
OverAggregateJsonPlanITCase.java
No new revisions were added by this update.
Summary of changes:
.../exec/stream/OverAggregateJsonPlanTest.java | 200 ---------
.../exec/stream/OverAggregateRestoreTest.java | 42 ++
.../exec/stream/OverAggregateTestPrograms.java | 235 +++++++++++
.../jsonplan/OverAggregateJsonPlanITCase.java | 202 ---------
.../testProcTimeBoundedNonPartitionedRangeOver.out | 456 --------------------
...undedPartitionedRowsOverWithBuiltinProctime.out | 449 --------------------
.../testRowTimeBoundedPartitionedRowsOver.out | 317 --------------
...er-aggregate-bounded-non-partitioned-rows.json} | 465 ++++++++++++---------
.../savepoint/_metadata | Bin 0 -> 27838 bytes
...regate-bounded-partitioned-preceding-rows.json} | 455 ++++++++++++--------
.../savepoint/_metadata | Bin 0 -> 28142 bytes
.../over-aggregate-bounded-partitioned-rows.json} | 425 ++++++++++---------
.../savepoint/_metadata | Bin 0 -> 27838 bytes
...over-aggregate-unbounded-partitioned-rows.json} | 447 ++++++++++++--------
.../savepoint/_metadata | Bin 0 -> 25506 bytes
15 files changed, 1299 insertions(+), 2394 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateRestoreTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateTestPrograms.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/OverAggregateJsonPlanITCase.java
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedNonPartitionedRangeOver.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRowsOverWithBuiltinProctime.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testRowTimeBoundedPartitionedRowsOver.out
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRangeOver.out
=>
restore-tests/stream-exec-over-aggregate_1/over-aggregate-bounded-non-partitioned-rows/plan/over-aggregate-bounded-non-partitioned-rows.json}
(56%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-bounded-non-partitioned-rows/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctPartitionedRowOver.out
=>
restore-tests/stream-exec-over-aggregate_1/over-aggregate-bounded-partitioned-preceding-rows/plan/over-aggregate-bounded-partitioned-preceding-rows.json}
(56%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-bounded-partitioned-preceding-rows/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctWithNonDistinctPartitionedRowOver.out
=>
restore-tests/stream-exec-over-aggregate_1/over-aggregate-bounded-partitioned-rows/plan/over-aggregate-bounded-partitioned-rows.json}
(66%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-bounded-partitioned-rows/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeUnboundedPartitionedRangeOver.out
=>
restore-tests/stream-exec-over-aggregate_1/over-aggregate-unbounded-partitioned-rows/plan/over-aggregate-unbounded-partitioned-rows.json}
(56%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-unbounded-partitioned-rows/savepoint/_metadata
