You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2023/01/31 11:18:45 UTC
[flink] 01/05: [FLINK-30823][runtime] Enable speculative execution for DiscardingSink
This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7894fe56cd92d423a20302ea488b075507c20bbd
Author: ifndef-SleePy <mm...@gmail.com>
AuthorDate: Mon Jan 30 18:02:39 2023 +0800
[FLINK-30823][runtime] Enable speculative execution for DiscardingSink
---
.../org/apache/flink/streaming/api/functions/sink/DiscardingSink.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/DiscardingSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/DiscardingSink.java
index 8bd7f69ef26..6a80a624186 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/DiscardingSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/DiscardingSink.java
@@ -19,6 +19,7 @@
package org.apache.flink.streaming.api.functions.sink;
import org.apache.flink.annotation.Public;
+import org.apache.flink.api.common.SupportsConcurrentExecutionAttempts;
/**
* A stream sink that ignores all elements.
@@ -26,7 +27,7 @@ import org.apache.flink.annotation.Public;
* @param <T> The type of elements received by the sink.
*/
@Public
-public class DiscardingSink<T> implements SinkFunction<T> {
+public class DiscardingSink<T> implements SinkFunction<T>, SupportsConcurrentExecutionAttempts {
private static final long serialVersionUID = 1L;