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 82116865b01 [FLINK-34649][table] Migrate
PushFilterIntoLegacyTableSourceScanRule to java
new 0dc2a0f74cf [FLINK-33676] Implement RestoreTests for WindowAggregate
new 68cc61a8618 [FLINK-33676] Deleting WindowAggregateJsonPlanTest.java
and WindowAggregateJsonITCase.java
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../WindowAggregateEventTimeRestoreTest.java | 65 +++
.../exec/stream/WindowAggregateJsonPlanTest.java | 528 --------------------
.../exec/stream/WindowAggregateTestPrograms.java | 538 +++++++++++++++++++++
.../stream/jsonplan/WindowAggregateJsonITCase.java | 243 ----------
.../testEventTimeSessionWindowWithPartitionKey.out | 373 --------------
...stEventTimeSessionWindowWithoutPartitionKey.out | 355 --------------
.../testProcTimeCumulateWindowWithCDCSource.out | 474 ------------------
.../testProcTimeHopWindow.out | 473 ------------------
.../testProcTimeHopWindowWithCDCSource.out | 474 ------------------
.../testProcTimeSessionWindowWithPartitionKey.out | 460 ------------------
...estProcTimeSessionWindowWithoutPartitionKey.out | 432 -----------------
.../testProcTimeTumbleWindow.out | 459 ------------------
.../testProcTimeTumbleWindowWithCDCSource.out | 460 ------------------
...ulate-event-time-two-phase-distinct-split.json} | 333 ++++++-------
.../savepoint/_metadata | Bin 0 -> 29761 bytes
...cumulate-event-time-two-phase-with-offset.json} | 315 +++++-------
.../savepoint/_metadata | Bin 0 -> 23185 bytes
...w-aggregate-cumulate-event-time-two-phase.json} | 306 ++++--------
.../savepoint/_metadata | Bin 0 -> 23181 bytes
...ate-event-time-with-offset-distinct-split.json} | 337 ++++++-------
.../savepoint/_metadata | Bin 0 -> 29761 bytes
...aggregate-cumulate-event-time-with-offset.json} | 301 ++++++------
.../savepoint/_metadata | Bin 0 -> 23134 bytes
.../window-aggregate-cumulate-event-time.json} | 299 ++++++------
.../savepoint/_metadata | Bin 0 -> 23134 bytes
...e-hop-event-time-two-phase-distinct-split.json} | 343 ++++++-------
.../savepoint/_metadata | Bin 0 -> 30037 bytes
...time-two-phase-with-offset-distinct-split.json} | 347 +++++++------
.../savepoint/_metadata | Bin 0 -> 30031 bytes
...gate-hop-event-time-two-phase-with-offset.json} | 308 +++++-------
.../savepoint/_metadata | Bin 0 -> 23049 bytes
...window-aggregate-hop-event-time-two-phase.json} | 306 ++++--------
.../savepoint/_metadata | Bin 0 -> 23045 bytes
...ndow-aggregate-hop-event-time-with-offset.json} | 308 ++++++------
.../savepoint/_metadata | Bin 0 -> 22998 bytes
.../plan/window-aggregate-hop-event-time.json} | 305 ++++++------
.../savepoint/_metadata | Bin 0 -> 22994 bytes
...ssion-event-time-two-phase-distinct-split.json} | 363 +++++++-------
.../savepoint/_metadata | Bin 0 -> 31910 bytes
...ow-aggregate-session-event-time-two-phase.json} | 411 ++++++++--------
.../savepoint/_metadata | Bin 0 -> 31476 bytes
.../plan/window-aggregate-session-event-time.json} | 365 +++++++-------
.../savepoint/_metadata | Bin 0 -> 31472 bytes
...ition-event-time-two-phase-distinct-split.json} | 266 +++++-----
.../savepoint/_metadata | Bin 0 -> 23641 bytes
...te-session-partition-event-time-two-phase.json} | 305 ++++++------
.../savepoint/_metadata | Bin 0 -> 23215 bytes
...ow-aggregate-session-partition-event-time.json} | 265 +++++-----
.../savepoint/_metadata | Bin 0 -> 23219 bytes
...umble-event-time-two-phase-distinct-split.json} | 337 ++++++-------
.../savepoint/_metadata | Bin 0 -> 29223 bytes
...time-two-phase-with-offset-distinct-split.json} | 341 ++++++-------
.../savepoint/_metadata | Bin 0 -> 29223 bytes
...e-tumble-event-time-two-phase-with-offset.json} | 300 ++++--------
.../savepoint/_metadata | Bin 0 -> 22637 bytes
...dow-aggregate-tumble-event-time-two-phase.json} | 296 ++++--------
.../savepoint/_metadata | Bin 0 -> 22637 bytes
...w-aggregate-tumble-event-time-with-offset.json} | 305 ++++++------
.../savepoint/_metadata | Bin 0 -> 22590 bytes
.../plan/window-aggregate-tumble-event-time.json} | 267 +++++-----
.../savepoint/_metadata | Bin 0 -> 22586 bytes
.../plan/window-aggregate-tumble-proc-time.json} | 271 ++++++-----
.../savepoint/_metadata | Bin 0 -> 18217 bytes
63 files changed, 4071 insertions(+), 9163 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateEventTimeRestoreTest.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateTestPrograms.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/WindowAggregateJsonITCase.java
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeSessionWindowWithPartitionKey.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeSessionWindowWithoutPartitionKey.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeCumulateWindowWithCDCSource.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindowWithCDCSource.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindowWithPartitionKey.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindowWithoutPartitionKey.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
delete mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindowWithCDCSource.out
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-two-phase-distinct-split/plan/window-aggregate-cumulate-event-time-two-phase-distinct-split.json}
(72%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-two-phase-distinct-split/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindowWithCDCSource.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-two-phase-with-offset/plan/window-aggregate-cumulate-event-time-two-phase-with-offset.json}
(64%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-two-phase-with-offset/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-two-phase/plan/window-aggregate-cumulate-event-time-two-phase.json}
(65%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-two-phase/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-with-offset-distinct-split/plan/window-aggregate-cumulate-event-time-with-offset-distinct-split.json}
(72%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-with-offset-distinct-split/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-with-offset/plan/window-aggregate-cumulate-event-time-with-offset.json}
(68%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time-with-offset/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithCDCSource.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time/plan/window-aggregate-cumulate-event-time.json}
(68%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-cumulate-event-time/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase-distinct-split/plan/window-aggregate-hop-event-time-two-phase-distinct-split.json}
(71%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase-distinct-split/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase-with-offset-distinct-split/plan/window-aggregate-hop-event-time-two-phase-with-offset-distinct-split.json}
(71%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase-with-offset-distinct-split/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase-with-offset/plan/window-aggregate-hop-event-time-two-phase-with-offset.json}
(65%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase-with-offset/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase/plan/window-aggregate-hop-event-time-two-phase.json}
(65%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-two-phase/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindowWithOffset.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-with-offset/plan/window-aggregate-hop-event-time-with-offset.json}
(67%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time-with-offset/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time/plan/window-aggregate-hop-event-time.json}
(67%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-hop-event-time/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindowWithCDCSource.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-event-time-two-phase-distinct-split/plan/window-aggregate-session-event-time-two-phase-distinct-split.json}
(62%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-event-time-two-phase-distinct-split/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-event-time-two-phase/plan/window-aggregate-session-event-time-two-phase.json}
(61%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-event-time-two-phase/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-event-time/plan/window-aggregate-session-event-time.json}
(63%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-event-time/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithCDCSource.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-partition-event-time-two-phase-distinct-split/plan/window-aggregate-session-partition-event-time-two-phase-distinct-split.json}
(70%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-partition-event-time-two-phase-distinct-split/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-partition-event-time-two-phase/plan/window-aggregate-session-partition-event-time-two-phase.json}
(68%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-partition-event-time-two-phase/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindow.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-partition-event-time/plan/window-aggregate-session-partition-event-time.json}
(70%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-session-partition-event-time/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase-distinct-split/plan/window-aggregate-tumble-event-time-two-phase-distinct-split.json}
(72%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase-distinct-split/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase-with-offset-distinct-split/plan/window-aggregate-tumble-event-time-two-phase-with-offset-distinct-split.json}
(72%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase-with-offset-distinct-split/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindowWithOffset.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase-with-offset/plan/window-aggregate-tumble-event-time-two-phase-with-offset.json}
(65%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase-with-offset/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase/plan/window-aggregate-tumble-event-time-two-phase.json}
(65%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-two-phase/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithCDCSource.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-with-offset/plan/window-aggregate-tumble-event-time-with-offset.json}
(68%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time-with-offset/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time/plan/window-aggregate-tumble-event-time.json}
(70%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-event-time/savepoint/_metadata
rename
flink-table/flink-table-planner/src/test/resources/{org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeCumulateWindow.out
=>
restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-proc-time/plan/window-aggregate-tumble-proc-time.json}
(66%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-window-aggregate_1/window-aggregate-tumble-proc-time/savepoint/_metadata
