This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 58e0ed2ab39d216495fb6dd06598a9717b3edc02 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(); }
