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 2017/06/25 11:50:31 UTC
[10/10] flink git commit: [FLINK-5892] Enable 1.2 keyed state test
[FLINK-5892] Enable 1.2 keyed state test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0fd3683c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0fd3683c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0fd3683c
Branch: refs/heads/release-1.3
Commit: 0fd3683c3489d98c5c82d21b9a7a5ee93c0d6b2e
Parents: b20ae53
Author: zentol <ch...@apache.org>
Authored: Mon May 8 11:56:57 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Sun Jun 25 09:00:49 2017 +0200
----------------------------------------------------------------------
.../state/operator/restore/keyed/KeyedJob.java | 14 ++++++--------
.../complexKeyed-flink1.2/_metadata | Bin 137490 -> 134953 bytes
2 files changed, 6 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0fd3683c/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/KeyedJob.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/KeyedJob.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/KeyedJob.java
index 523e937..95d0efc 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/KeyedJob.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/KeyedJob.java
@@ -98,10 +98,9 @@ public class KeyedJob {
.map(new StatefulStringStoringMap(mode, "first"))
.setParallelism(4);
- // TODO: re-enable this when generating the actual 1.2 savepoint
- //if (mode == ExecutionMode.MIGRATE || mode == ExecutionMode.RESTORE) {
- map.uid("first");
- //}
+ if (mode == ExecutionMode.MIGRATE || mode == ExecutionMode.RESTORE) {
+ map.uid("first");
+ }
return map;
}
@@ -111,10 +110,9 @@ public class KeyedJob {
.map(new StatefulStringStoringMap(mode, "second"))
.setParallelism(4);
- // TODO: re-enable this when generating the actual 1.2 savepoint
- //if (mode == ExecutionMode.MIGRATE || mode == ExecutionMode.RESTORE) {
- map.uid("second");
- //}
+ if (mode == ExecutionMode.MIGRATE || mode == ExecutionMode.RESTORE) {
+ map.uid("second");
+ }
return map;
}
http://git-wip-us.apache.org/repos/asf/flink/blob/0fd3683c/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.2/_metadata
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.2/_metadata b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.2/_metadata
index 9e03876..0a1ed10 100644
Binary files a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.2/_metadata and b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.2/_metadata differ