You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/08/14 08:04:57 UTC
[flink] 04/06: [FLINK-10091][tests] Update
WindowOperatorMigrationTest for 1.5
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
commit a09be8f75dc43b60f618b1e37662ac67f5fa0135
Author: zentol <ch...@apache.org>
AuthorDate: Tue Aug 7 13:18:37 2018 +0200
[FLINK-10091][tests] Update WindowOperatorMigrationTest for 1.5
---
.../windowing/WindowOperatorMigrationTest.java | 2 +-
...op-migration-test-apply-event-time-flink1.5-snapshot | Bin 0 -> 4980 bytes
...gration-test-apply-processing-time-flink1.5-snapshot | Bin 0 -> 4872 bytes
...migration-test-kryo-serialized-key-flink1.5-snapshot | Bin 0 -> 10279 bytes
...p-migration-test-reduce-event-time-flink1.5-snapshot | Bin 0 -> 3840 bytes
...ration-test-reduce-processing-time-flink1.5-snapshot | Bin 0 -> 3781 bytes
...test-session-with-stateful-trigger-flink1.5-snapshot | Bin 0 -> 9037 bytes
...session-with-stateful-trigger-mint-flink1.5-snapshot | Bin 0 -> 8008 bytes
8 files changed, 1 insertion(+), 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 2f2c751..44fd374 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
@@ -86,7 +86,7 @@ public class WindowOperatorMigrationTest {
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3, MigrationVersion.v1_4);
+ return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3, MigrationVersion.v1_4, MigrationVersion.v1_5);
}
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.5-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.5-snapshot
new file mode 100644
index 0000000..2fd8075
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.5-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.5-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.5-snapshot
new file mode 100644
index 0000000..ccc84e1
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.5-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.5-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.5-snapshot
new file mode 100644
index 0000000..b9ccd04
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.5-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.5-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.5-snapshot
new file mode 100644
index 0000000..22f5db6
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.5-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.5-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.5-snapshot
new file mode 100644
index 0000000..1005180
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.5-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.5-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.5-snapshot
new file mode 100644
index 0000000..9046b5b
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.5-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.5-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.5-snapshot
new file mode 100644
index 0000000..e585d53
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.5-snapshot differ