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();
        }

Reply via email to