This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 34ce59bf3915f992d192bd10cc4c8bda285a44dd Author: Zhijiang <[email protected]> AuthorDate: Thu Jun 27 13:10:59 2019 +0800 [hotfix][runtime] add checkNotNull for parameters in ResultPartitionID constructor --- .../flink/runtime/io/network/partition/ResultPartitionID.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java index 317d17f..fd6e68b 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java @@ -25,6 +25,8 @@ import org.apache.flink.runtime.jobgraph.IntermediateResultPartitionID; import java.io.Serializable; +import static org.apache.flink.util.Preconditions.checkNotNull; + /** * Runtime identifier of a produced {@link IntermediateResultPartition}. * @@ -46,8 +48,8 @@ public final class ResultPartitionID implements Serializable { } public ResultPartitionID(IntermediateResultPartitionID partitionId, ExecutionAttemptID producerId) { - this.partitionId = partitionId; - this.producerId = producerId; + this.partitionId = checkNotNull(partitionId); + this.producerId = checkNotNull(producerId); } public IntermediateResultPartitionID getPartitionId() {
