diff --git a/flink-core/src/main/java/org/apache/flink/api/connector/source/SplitEnumeratorContext.java b/flink-core/src/main/java/org/apache/flink/api/connector/source/SplitEnumeratorContext.java index 3990f65e26c32..6c3637b27728c 100644 --- a/flink-core/src/main/java/org/apache/flink/api/connector/source/SplitEnumeratorContext.java +++ b/flink-core/src/main/java/org/apache/flink/api/connector/source/SplitEnumeratorContext.java @@ -195,5 +195,7 @@ void callAsync( * source is considered to have isProcessingBacklog=false by default. */ @PublicEvolving - void setIsProcessingBacklog(boolean isProcessingBacklog); + default void setIsProcessingBacklog(boolean isProcessingBacklog) { + throw new UnsupportedOperationException(); + } }