[streaming] Change 'getParallelism()' signature to return a primitive…

… to avoid failed equality checks.
VonRosenchild · Apr 29, 2015 · 421e4a1 · 421e4a1
1 parent 0fceb11
commit 421e4a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...g/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java b/...g/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
@@ -118,7 +118,7 @@ public Integer getID() {
  return ID;
  }
 
- public Integer getParallelism() {
+ public int getParallelism() {
  return parallelism != null ? parallelism : env.getParallelism();
  }