You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/05/27 20:00:57 UTC
[flink] 01/16: [hotfix][runtime] Annotate ProcessingTimeCallback as
a FunctionalInterface
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 506819f1dd60d8e0c68d12a7213849a76d0b345e
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Sun May 24 20:21:16 2020 +0200
[hotfix][runtime] Annotate ProcessingTimeCallback as a FunctionalInterface
The interface is used as such throught the runtime already, but is missing the annotation
to guard the SAM nature.
---
.../org/apache/flink/streaming/runtime/tasks/ProcessingTimeCallback.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeCallback.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeCallback.java
index 9bccae0..4604380 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeCallback.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeCallback.java
@@ -25,6 +25,7 @@ import org.apache.flink.annotation.Internal;
* {@link ProcessingTimeService}.
*/
@Internal
+@FunctionalInterface
public interface ProcessingTimeCallback {
/**