[FLINK-30823][runtime] Enable speculative execution for PrintSinkFunc…

…tion
changzhiwin · Jan 31, 2023 · 886b1f1 · 886b1f1
1 parent 7894fe5
commit 886b1f1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...g-java/src/main/java/org/apache/flink/streaming/api/functions/sink/PrintSinkFunction.java b/...g-java/src/main/java/org/apache/flink/streaming/api/functions/sink/PrintSinkFunction.java
@@ -18,6 +18,7 @@
 package org.apache.flink.streaming.api.functions.sink;
 
 import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.api.common.SupportsConcurrentExecutionAttempts;
 import org.apache.flink.api.common.functions.util.PrintSinkOutputWriter;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;
@@ -34,7 +35,8 @@
  * @param <IN> Input record type
  */
 @PublicEvolving
-public class PrintSinkFunction<IN> extends RichSinkFunction<IN> {
+public class PrintSinkFunction<IN> extends RichSinkFunction<IN>
+        implements SupportsConcurrentExecutionAttempts {
 
     private static final long serialVersionUID = 1L;