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 2015/04/29 11:55:44 UTC
[4/5] flink git commit: [streaming] Change 'getParallelism()'
signature to return a primitive to avoid failed equality checks.
[streaming] Change 'getParallelism()' signature to return a primitive to avoid failed equality checks.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/421e4a1b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/421e4a1b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/421e4a1b
Branch: refs/heads/master
Commit: 421e4a1bf6599242829f24d25f4a464ee6438bc5
Parents: 0fceb11
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Apr 24 13:25:18 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Wed Apr 29 10:41:10 2015 +0200
----------------------------------------------------------------------
.../main/java/org/apache/flink/streaming/api/graph/StreamNode.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/421e4a1b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
index 576150e..9672035 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
@@ -118,7 +118,7 @@ public class StreamNode implements Serializable {
return ID;
}
- public Integer getParallelism() {
+ public int getParallelism() {
return parallelism != null ? parallelism : env.getParallelism();
}