You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2019/08/01 11:45:05 UTC
[flink] 05/13: [hotfix][network] fix codestyle issues in
NettyShuffleMaster
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 <az...@gmail.com>
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 ?