flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [1/9] flink git commit: [FLINK-5438] [streaming api] Typo in JobGraph generator Exception
Date Mon, 16 Jan 2017 20:13:43 GMT
Repository: flink
Updated Branches:
  refs/heads/master ef8cdfe59 -> 7a339a65f


[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/c2f28c01
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c2f28c01
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c2f28c01

Branch: refs/heads/master
Commit: c2f28c013116328583043ca1433c45c85e32de30
Parents: fa67ef4
Author: mtunique <oatgnem@gmail.com>
Authored: Thu Jan 12 12:02:49 2017 +0800
Committer: Stephan Ewen <sewen@apache.org>
Committed: Mon Jan 16 20:18:47 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/c2f28c01/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());


Mime
View raw message