You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gy...@apache.org on 2015/01/31 11:11:20 UTC
flink git commit: [FLINK-1425] [streaming] Non-lazy scheduling set
for streaming programs
Repository: flink
Updated Branches:
refs/heads/master f7e84c157 -> 389683125
[FLINK-1425] [streaming] Non-lazy scheduling set for streaming programs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38968312
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/38968312
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/38968312
Branch: refs/heads/master
Commit: 3896831253100b1fa5935fc5bab4b7222aeabedf
Parents: f7e84c1
Author: Gyula Fora <gy...@apache.org>
Authored: Sat Jan 31 08:54:56 2015 +0100
Committer: Gyula Fora <gy...@apache.org>
Committed: Sat Jan 31 08:55:59 2015 +0100
----------------------------------------------------------------------
.../apache/flink/streaming/api/StreamingJobGraphGenerator.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/38968312/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamingJobGraphGenerator.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamingJobGraphGenerator.java b/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamingJobGraphGenerator.java
index d9a1b66..24ebf46 100644
--- a/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamingJobGraphGenerator.java
+++ b/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamingJobGraphGenerator.java
@@ -30,6 +30,7 @@ import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.jobgraph.AbstractJobVertex;
import org.apache.flink.runtime.jobgraph.DistributionPattern;
import org.apache.flink.runtime.jobgraph.JobGraph;
+import org.apache.flink.runtime.jobgraph.ScheduleMode;
import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;
import org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup;
import org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup;
@@ -70,6 +71,9 @@ public class StreamingJobGraphGenerator {
public JobGraph createJobGraph(String jobName) {
jobGraph = new JobGraph(jobName);
+ // Turn lazy scheduling off
+ jobGraph.setScheduleMode(ScheduleMode.ALL);
+
init();
for (String sourceName : streamGraph.getSources()) {