You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/11/27 13:33:22 UTC
[2/2] flink git commit: [hofix] Properly set state backend from
execution environment to stream graph
[hofix] Properly set state backend from execution environment to stream graph
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e69d1452
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e69d1452
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e69d1452
Branch: refs/heads/master
Commit: e69d14521117b34054aa643398febafefdc1834f
Parents: e4a4eff
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Nov 27 13:20:23 2015 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Nov 27 13:20:23 2015 +0100
----------------------------------------------------------------------
.../org/apache/flink/streaming/api/graph/StreamGraphGenerator.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e69d1452/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
index 4bd7a73..3eaa8cc 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
@@ -98,6 +98,7 @@ public class StreamGraphGenerator {
private StreamGraphGenerator(StreamExecutionEnvironment env) {
this.streamGraph = new StreamGraph(env);
this.streamGraph.setChaining(env.isChainingEnabled());
+ this.streamGraph.setStateBackend(env.getStateBackend());
this.env = env;
this.alreadyTransformed = new HashMap<>();
}