This is an automated email from the ASF dual-hosted git repository. zhijiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit f810a1a20e104dfbfcb26f547828e4080022cbe8 Author: Andrey Zagrebin <[email protected]> AuthorDate: Mon Jul 29 17:30:44 2019 +0300 [hotfix][network] fix codestyle issues in NettyShuffleMaster --- .../main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java index 6c2cb32..50c11cf 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java @@ -21,6 +21,7 @@ package org.apache.flink.runtime.shuffle; import org.apache.flink.runtime.io.network.partition.ResultPartitionID; import org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.LocalExecutionPartitionConnectionInfo; import org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.NetworkPartitionConnectionInfo; +import org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.PartitionConnectionInfo; import java.util.concurrent.CompletableFuture; @@ -51,7 +52,7 @@ public enum NettyShuffleMaster implements ShuffleMaster<NettyShuffleDescriptor> public void releasePartitionExternally(ShuffleDescriptor shuffleDescriptor) { } - private static NettyShuffleDescriptor.PartitionConnectionInfo createConnectionInfo( + private static PartitionConnectionInfo createConnectionInfo( ProducerDescriptor producerDescriptor, int connectionIndex) { return producerDescriptor.getDataPort() >= 0 ?
