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 7ee937c16088ffcc0d75de64d89dca12be52ec5a Author: Andrey Zagrebin <[email protected]> AuthorDate: Mon Jul 29 17:29:34 2019 +0300 [hotfix][network] Annotate NettyShuffleDescriptor#PartitionConnectionInfo with @FunctionalInterface --- .../java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java b/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java index f758bcc..cf58b97 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java @@ -70,6 +70,7 @@ public class NettyShuffleDescriptor implements ShuffleDescriptor { /** * Information for connection to partition producer for shuffle exchange. */ + @FunctionalInterface public interface PartitionConnectionInfo extends Serializable { ConnectionID getConnectionId(); }
