This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit ab28f7430f4747ce43be79b653de99e43a3e6efe
Author: Yun Gao <gaoyunhen...@gmail.com>
AuthorDate: Sat May 7 18:23:16 2022 +0800
[release] Upgrade current version to 1.15 for WindowOperatorMigrationTest
and create snapshots
---
.../operators/windowing/WindowOperatorMigrationTest.java | 15 +--------------
...op-migration-test-apply-event-time-flink1.15-snapshot | Bin 0 -> 1799 bytes
...gration-test-apply-processing-time-flink1.15-snapshot | Bin 0 -> 1691 bytes
...migration-test-kryo-serialized-key-flink1.15-snapshot | Bin 0 -> 4021 bytes
...p-migration-test-reduce-event-time-flink1.15-snapshot | Bin 0 -> 1655 bytes
...ration-test-reduce-processing-time-flink1.15-snapshot | Bin 0 -> 1596 bytes
...test-session-with-stateful-trigger-flink1.15-snapshot | Bin 0 -> 2707 bytes
...session-with-stateful-trigger-mint-flink1.15-snapshot | Bin 0 -> 2201 bytes
8 files changed, 1 insertion(+), 14 deletions(-)
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 5d34b7eb5f4..33da08f1fc0 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
@@ -61,7 +61,6 @@ import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
-import java.util.Arrays;
import java.util.Collection;
import java.util.Comparator;
import java.util.concurrent.ConcurrentLinkedQueue;
@@ -85,19 +84,7 @@ public class WindowOperatorMigrationTest {
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection<FlinkVersion> parameters() {
- return Arrays.asList(
- FlinkVersion.v1_3,
- FlinkVersion.v1_4,
- FlinkVersion.v1_5,
- FlinkVersion.v1_6,
- FlinkVersion.v1_7,
- FlinkVersion.v1_8,
- FlinkVersion.v1_9,
- FlinkVersion.v1_10,
- FlinkVersion.v1_11,
- FlinkVersion.v1_12,
- FlinkVersion.v1_13,
- FlinkVersion.v1_14);
+ return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_15);
}
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.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.15-snapshot
new file mode 100644
index 00000000000..0aa53ce4408
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.15-snapshot
new file mode 100644
index 00000000000..a8f3ab38bfb
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.15-snapshot
new file mode 100644
index 00000000000..2afb02375bb
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.15-snapshot
new file mode 100644
index 00000000000..eca89981174
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.15-snapshot
new file mode 100644
index 00000000000..ade4333cb36
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.15-snapshot
new file mode 100644
index 00000000000..7ed4eb9a052
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.15-snapshot
new file mode 100644
index 00000000000..9d07d0eedbe
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.15-snapshot
differ
