diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java index 2e357c4510553..2df094b06e72a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java @@ -18,8 +18,8 @@ package org.apache.flink.runtime.io.network.netty; -import org.apache.flink.runtime.io.network.NetworkClientHandler; import org.apache.flink.runtime.io.network.ConnectionID; +import org.apache.flink.runtime.io.network.NetworkClientHandler; import org.apache.flink.runtime.io.network.netty.exception.LocalTransportException; import org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException; import org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel; @@ -34,8 +34,8 @@ /** * Factory for {@link PartitionRequestClient} instances. - *

- * Instances of partition requests clients are shared among several {@link RemoteInputChannel} + * + *

Instances of partition requests clients are shared among several {@link RemoteInputChannel} * instances. */ class PartitionRequestClientFactory {