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 2019/01/09 09:56:57 UTC
[flink] branch master updated: [FLINK-10783][tests] Update
WindowOperatorMigrationTest for 1.7
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 78cc9bc [FLINK-10783][tests] Update WindowOperatorMigrationTest for 1.7
78cc9bc is described below
commit 78cc9bc8b7c9ff2806fa6176ec15f38199fe6b25
Author: boshu Zheng <bl...@gmail.com>
AuthorDate: Wed Jan 9 17:56:49 2019 +0800
[FLINK-10783][tests] Update WindowOperatorMigrationTest for 1.7
---
.../windowing/WindowOperatorMigrationTest.java | 3 ++-
...op-migration-test-apply-event-time-flink1.7-snapshot | Bin 0 -> 6465 bytes
...gration-test-apply-processing-time-flink1.7-snapshot | Bin 0 -> 6357 bytes
...migration-test-kryo-serialized-key-flink1.7-snapshot | Bin 0 -> 21981 bytes
...p-migration-test-reduce-event-time-flink1.7-snapshot | Bin 0 -> 6329 bytes
...ration-test-reduce-processing-time-flink1.7-snapshot | Bin 0 -> 6270 bytes
...test-session-with-stateful-trigger-flink1.7-snapshot | Bin 0 -> 9972 bytes
...session-with-stateful-trigger-mint-flink1.7-snapshot | Bin 0 -> 9112 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 0168a7b..f4883c9 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
@@ -91,7 +91,8 @@ public class WindowOperatorMigrationTest {
MigrationVersion.v1_3,
MigrationVersion.v1_4,
MigrationVersion.v1_5,
- MigrationVersion.v1_6);
+ MigrationVersion.v1_6,
+ MigrationVersion.v1_7);
}
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.7-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.7-snapshot
new file mode 100644
index 0000000..0051be0
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.7-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.7-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.7-snapshot
new file mode 100644
index 0000000..38bbc7e
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.7-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.7-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.7-snapshot
new file mode 100644
index 0000000..df7866b
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.7-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.7-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.7-snapshot
new file mode 100644
index 0000000..6fe2896
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.7-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.7-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.7-snapshot
new file mode 100644
index 0000000..a6d1863
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.7-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.7-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.7-snapshot
new file mode 100644
index 0000000..0268926
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.7-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.7-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.7-snapshot
new file mode 100644
index 0000000..e93debd
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.7-snapshot differ