Package org.apache.flink.api.common
Interface SupportsConcurrentExecutionAttempts
-
@PublicEvolving public interface SupportsConcurrentExecutionAttemptsThe interface indicates that it supports multiple attempts executing at the same time.Currently, the interface is used for speculative execution. If a sink implementation (SinkV2, OutputFormat or SinkFunction) inherits this interface, the sink operator would be considered to support speculative execution.