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 2017/01/16 20:17:44 UTC
[2/7] flink git commit: [FLINK-5438] [streaming api] Typo in JobGraph
generator Exception
[FLINK-5438] [streaming api] Typo in JobGraph generator Exception
This closes #3098
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30b467f2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30b467f2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/30b467f2
Branch: refs/heads/release-1.2
Commit: 30b467f266970e267792411d3148b4379ec23439
Parents: 119d39b
Author: mtunique <oa...@gmail.com>
Authored: Thu Jan 12 12:02:49 2017 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Jan 16 15:37:33 2017 +0100
----------------------------------------------------------------------
.../flink/streaming/api/graph/StreamingJobGraphGenerator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/30b467f2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
index 0cb7d9a..1bfaf3f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
@@ -317,7 +317,7 @@ public class StreamingJobGraphGenerator {
// the parallelism should always be smaller or equal than the max parallelism
throw new IllegalStateException("The maximum parallelism (" + maxParallelism + ") of " +
"the stream node " + streamNode + " is smaller than the parallelism (" +
- parallelism + "). Increase the maximum parallelism or decrease the parallelism of" +
+ parallelism + "). Increase the maximum parallelism or decrease the parallelism of " +
"this operator.");
} else {
jobVertex.setMaxParallelism(streamNode.getMaxParallelism());