You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2021/05/26 15:26:33 UTC
[flink] 01/01: Constant NO_OP Autocloseable
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch benchmark-request
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 39acb9b1ac0b42d806b6d5dc8cd476d6027ec9a8
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Wed May 26 10:54:57 2021 +0200
Constant NO_OP Autocloseable
---
.../flink/streaming/runtime/streamstatus/AnnouncedStatus.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/AnnouncedStatus.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/AnnouncedStatus.java
index 3cd055b..209c6c8 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/AnnouncedStatus.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/AnnouncedStatus.java
@@ -30,6 +30,12 @@ import java.util.function.Consumer;
*/
@Internal
public final class AnnouncedStatus {
+ private static final AutoCloseable NO_OP =
+ new AutoCloseable() {
+ @Override
+ public void close() {}
+ };
+
private StreamStatus currentStatus;
public AnnouncedStatus(StreamStatus currentStatus) {
@@ -65,6 +71,6 @@ public final class AnnouncedStatus {
statusConsumer.accept(StreamStatus.ACTIVE);
return () -> statusConsumer.accept(StreamStatus.IDLE);
}
- return () -> {};
+ return NO_OP;
}
}