You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2021/02/22 02:30:07 UTC
[flink] 07/13: [FLINK-20536][tests] Update migration tests of
WindowOperatorMigrationTest to cover migration from 1.12
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7e164822ca7428cb7ac5739958dbbd29d994c0bd
Author: Dian Fu <di...@apache.org>
AuthorDate: Fri Feb 19 17:11:53 2021 +0800
[FLINK-20536][tests] Update migration tests of WindowOperatorMigrationTest to cover migration from 1.12
---
.../operators/windowing/WindowOperatorMigrationTest.java | 3 ++-
...op-migration-test-apply-event-time-flink1.12-snapshot | Bin 0 -> 1761 bytes
...gration-test-apply-processing-time-flink1.12-snapshot | Bin 0 -> 1653 bytes
...migration-test-kryo-serialized-key-flink1.12-snapshot | Bin 0 -> 3983 bytes
...p-migration-test-reduce-event-time-flink1.12-snapshot | Bin 0 -> 1617 bytes
...ration-test-reduce-processing-time-flink1.12-snapshot | Bin 0 -> 1558 bytes
...test-session-with-stateful-trigger-flink1.12-snapshot | Bin 0 -> 2669 bytes
...session-with-stateful-trigger-mint-flink1.12-snapshot | Bin 0 -> 2163 bytes
8 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
index 9d3fc1e..ae9f9e3 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
@@ -94,7 +94,8 @@ public class WindowOperatorMigrationTest {
MigrationVersion.v1_8,
MigrationVersion.v1_9,
MigrationVersion.v1_10,
- MigrationVersion.v1_11);
+ MigrationVersion.v1_11,
+ MigrationVersion.v1_12);
}
private static final TypeInformation<Tuple2<String, Integer>> STRING_INT_TUPLE =
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.12-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.12-snapshot
new file mode 100644
index 0000000..7f6fba3
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.12-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.12-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.12-snapshot
new file mode 100644
index 0000000..feaed2c
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.12-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.12-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.12-snapshot
new file mode 100644
index 0000000..74af9ca
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.12-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.12-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.12-snapshot
new file mode 100644
index 0000000..1ccdd4b
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.12-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.12-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.12-snapshot
new file mode 100644
index 0000000..feaada0
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.12-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.12-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.12-snapshot
new file mode 100644
index 0000000..3f73ea5
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.12-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.12-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.12-snapshot
new file mode 100644
index 0000000..ebc2bc2
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.12-snapshot differ