flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [2/2] flink git commit: [hofix] Properly set state backend from execution environment to stream graph
Date Fri, 27 Nov 2015 12:33:22 GMT
[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 <sewen@apache.org>
Authored: Fri Nov 27 13:20:23 2015 +0100
Committer: Stephan Ewen <sewen@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<>();
 	}


Mime
View raw message