You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2018/09/14 09:19:37 UTC
[flink] branch master updated: [FLINK-10321][network] Make the
condition of broadcast partitioner simple (#6688)
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new ac35710 [FLINK-10321][network] Make the condition of broadcast partitioner simple (#6688)
ac35710 is described below
commit ac35710218492e38e8a6f524e675e90f94b88012
Author: zhijiang <wa...@aliyun.com>
AuthorDate: Fri Sep 14 17:19:27 2018 +0800
[FLINK-10321][network] Make the condition of broadcast partitioner simple (#6688)
---
.../flink/streaming/runtime/partitioner/BroadcastPartitioner.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/BroadcastPartitioner.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/BroadcastPartitioner.java
index 3d0e108..c796813 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/BroadcastPartitioner.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/BroadcastPartitioner.java
@@ -30,22 +30,18 @@ import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
public class BroadcastPartitioner<T> extends StreamPartitioner<T> {
private static final long serialVersionUID = 1L;
- int[] returnArray;
- boolean set;
- int setNumber;
+ private int[] returnArray;
@Override
public int[] selectChannels(SerializationDelegate<StreamRecord<T>> record,
int numberOfOutputChannels) {
- if (set && setNumber == numberOfOutputChannels) {
+ if (returnArray != null && returnArray.length == numberOfOutputChannels) {
return returnArray;
} else {
this.returnArray = new int[numberOfOutputChannels];
for (int i = 0; i < numberOfOutputChannels; i++) {
returnArray[i] = i;
}
- set = true;
- setNumber = numberOfOutputChannels;
return returnArray;
}
}