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 <oatg...@gmail.com> Authored: Thu Jan 12 12:02:49 2017 +0800 Committer: Stephan Ewen <se...@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());
