This is an automated email from the ASF dual-hosted git repository. kunni pushed a commit to branch FLINK-38729-2 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 10e3747d86057a8832ae740b391260e2e63179d5 Author: lvyanquan <[email protected]> AuthorDate: Tue Mar 10 23:25:49 2026 +0800 Update java doc. --- flink-cdc-flink1.20-compat/pom.xml | 62 +--------------------- .../typeutils/TypeSerializerSnapshotAdapter.java | 8 ++- .../operators/AbstractStreamOperatorAdapter.java | 7 ++- .../apache/flink/runtime/event/WatermarkEvent.java | 8 ++- flink-cdc-flink2.2-compat/pom.xml | 62 +--------------------- .../typeutils/TypeSerializerSnapshotAdapter.java | 8 ++- .../org/apache/flink/api/connector/sink2/Sink.java | 12 +++-- .../connector/sink2/TwoPhaseCommittingSink.java | 8 ++- .../operators/AbstractStreamOperatorAdapter.java | 7 ++- .../apache/flink/core/execution/RestoreMode.java | 8 +-- .../runtime/jobgraph/SavepointConfigOptions.java | 9 ++-- .../connector/sink2/WithPostCommitTopology.java | 8 ++- .../api/connector/sink2/WithPreCommitTopology.java | 8 ++- .../api/connector/sink2/WithPreWriteTopology.java | 7 ++- .../streaming/api/functions/sink/SinkFunction.java | 8 ++- .../source/RichParallelSourceFunction.java | 9 ++-- .../api/functions/source/SourceFunction.java | 8 ++- .../api/operators/YieldingOperatorFactory.java | 8 ++- .../flink/table/api/ValidationException.java | 9 ++-- 19 files changed, 113 insertions(+), 151 deletions(-) diff --git a/flink-cdc-flink1.20-compat/pom.xml b/flink-cdc-flink1.20-compat/pom.xml index b65c53497..45a99cccd 100644 --- a/flink-cdc-flink1.20-compat/pom.xml +++ b/flink-cdc-flink1.20-compat/pom.xml @@ -32,64 +32,4 @@ limitations under the License. <shaded.guava.version>${flink.1.x.shaded.guava.version}</shaded.guava.version> </properties> - <dependencies> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-table-common</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-base</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-table-api-java-bridge</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-core</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-streaming-java</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.slf4j</groupId> - <artifactId>slf4j-api</artifactId> - <version>${slf4j.version}</version> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-shaded-guava</artifactId> - <version>${shaded.guava.version}</version> - </dependency> - </dependencies> - - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-jar-plugin</artifactId> - <executions> - <execution> - <id>test-jar</id> - <goals> - <goal>test-jar</goal> - </goals> - </execution> - </executions> - </plugin> - </plugins> - </build> - -</project> \ No newline at end of file +</project> diff --git a/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java b/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java index a74e14c97..b868b4fba 100644 --- a/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java +++ b/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java @@ -17,5 +17,11 @@ package org.apache.flink.api.common.typeutils; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 1.20. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface TypeSerializerSnapshotAdapter<T> extends TypeSerializerSnapshot<T> {} diff --git a/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java b/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java index b4fe16f5e..73c578b04 100644 --- a/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java +++ b/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java @@ -17,7 +17,12 @@ package org.apache.flink.cdc.runtime.operators; +import org.apache.flink.annotation.Internal; import org.apache.flink.streaming.api.operators.AbstractStreamOperator; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +/** + * Compatibility adapter for Flink 1.20. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public class AbstractStreamOperatorAdapter<OUT> extends AbstractStreamOperator<OUT> {} diff --git a/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/runtime/event/WatermarkEvent.java b/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/runtime/event/WatermarkEvent.java index afa423894..b9d7f7fb6 100644 --- a/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/runtime/event/WatermarkEvent.java +++ b/flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/runtime/event/WatermarkEvent.java @@ -17,5 +17,11 @@ package org.apache.flink.runtime.event; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 1.20. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public class WatermarkEvent {} diff --git a/flink-cdc-flink2.2-compat/pom.xml b/flink-cdc-flink2.2-compat/pom.xml index ffed8f2dc..5e755b2ee 100644 --- a/flink-cdc-flink2.2-compat/pom.xml +++ b/flink-cdc-flink2.2-compat/pom.xml @@ -32,64 +32,4 @@ limitations under the License. <shaded.guava.version>${flink.2.x.shaded.guava.version}</shaded.guava.version> </properties> - <dependencies> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-table-common</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-base</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-table-api-java-bridge</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-core</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-streaming-java</artifactId> - <version>${flink.version}</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.slf4j</groupId> - <artifactId>slf4j-api</artifactId> - <version>${slf4j.version}</version> - </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-shaded-guava</artifactId> - <version>${shaded.guava.version}</version> - </dependency> - </dependencies> - - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-jar-plugin</artifactId> - <executions> - <execution> - <id>test-jar</id> - <goals> - <goal>test-jar</goal> - </goals> - </execution> - </executions> - </plugin> - </plugins> - </build> - -</project> \ No newline at end of file +</project> diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java index a969801ee..5060d9219 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java @@ -17,7 +17,13 @@ package org.apache.flink.api.common.typeutils; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface TypeSerializerSnapshotAdapter<T> extends TypeSerializerSnapshot<T> { TypeSerializerSchemaCompatibility<T> resolveSchemaCompatibility( diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/Sink.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/Sink.java index f4b5d6d01..0b06d3f51 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/Sink.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/Sink.java @@ -18,8 +18,7 @@ package org.apache.flink.api.connector.sink2; import org.apache.flink.annotation.Experimental; -import org.apache.flink.annotation.Public; -import org.apache.flink.annotation.PublicEvolving; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.operators.MailboxExecutor; import org.apache.flink.api.common.operators.ProcessingTimeService; import org.apache.flink.api.common.serialization.SerializationSchema; @@ -32,8 +31,11 @@ import java.io.Serializable; import java.util.Optional; import java.util.function.Consumer; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ -@Public +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface Sink<InputT> extends Serializable { SinkWriter<InputT> createWriter(WriterInitContext var1) throws IOException; @@ -48,7 +50,7 @@ public interface Sink<InputT> extends Serializable { * @deprecated */ @Deprecated - @PublicEvolving + @Internal public interface InitContext extends org.apache.flink.api.connector.sink2.InitContext { UserCodeClassLoader getUserCodeClassLoader(); diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java index 86d0636a5..cae29dbfe 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java @@ -17,6 +17,12 @@ package org.apache.flink.api.connector.sink2; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface TwoPhaseCommittingSink<InputT, CommT> extends Sink<InputT>, SupportsCommitter<CommT> {} diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java index f8cdb6f25..e893db104 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java @@ -17,6 +17,7 @@ package org.apache.flink.cdc.runtime.operators; +import org.apache.flink.annotation.Internal; import org.apache.flink.streaming.api.graph.StreamConfig; import org.apache.flink.streaming.api.operators.AbstractStreamOperator; import org.apache.flink.streaming.api.operators.ChainingStrategy; @@ -24,7 +25,11 @@ import org.apache.flink.streaming.api.operators.Output; import org.apache.flink.streaming.runtime.streamrecord.StreamRecord; import org.apache.flink.streaming.runtime.tasks.StreamTask; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public class AbstractStreamOperatorAdapter<OUT> extends AbstractStreamOperator<OUT> { protected ChainingStrategy chainingStrategy; diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/core/execution/RestoreMode.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/core/execution/RestoreMode.java index 80227ea9b..6e7cca53f 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/core/execution/RestoreMode.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/core/execution/RestoreMode.java @@ -18,16 +18,18 @@ package org.apache.flink.core.execution; import org.apache.flink.annotation.Internal; -import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.configuration.DescribedEnum; import org.apache.flink.configuration.description.InlineElement; import org.apache.flink.configuration.description.TextElement; /** - * Copy from <a + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + * + * <p>Copy from <a * href="https://github.com/apache/flink/blob/release-1.20.3/flink-core/src/main/java/org/apache/flink/core/execution/RestoreMode.java";>...</a>. */ -@PublicEvolving +@Internal public enum RestoreMode implements DescribedEnum { CLAIM( "Flink will take ownership of the given snapshot. It will clean the snapshot once it is subsumed by newer ones."), diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java index f281c0ee4..83494815c 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java @@ -17,19 +17,22 @@ package org.apache.flink.runtime.jobgraph; -import org.apache.flink.annotation.PublicEvolving; +import org.apache.flink.annotation.Internal; import org.apache.flink.annotation.docs.Documentation; import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigOptions; import org.apache.flink.core.execution.RestoreMode; /** - * Copy from <a + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + * + * <p>Copy from <a * href="https://github.com/apache/flink/blob/release-1.20.3/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java";>...</a>. */ @Deprecated @Documentation.ExcludeFromDocumentation("Hidden for deprecated.") -@PublicEvolving +@Internal public class SavepointConfigOptions { public static final ConfigOption<String> SAVEPOINT_PATH = ConfigOptions.key("execution.savepoint.path") diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java index 1f0cb5c86..2fe0127b9 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java @@ -17,5 +17,11 @@ package org.apache.flink.streaming.api.connector.sink2; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface WithPostCommitTopology<InputT, CommT> extends SupportsPostCommitTopology<CommT> {} diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreCommitTopology.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreCommitTopology.java index eda582e47..de18bdb86 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreCommitTopology.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreCommitTopology.java @@ -17,6 +17,12 @@ package org.apache.flink.streaming.api.connector.sink2; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface WithPreCommitTopology<InputT, CommT> extends SupportsPreCommitTopology<CommT, CommT> {} diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreWriteTopology.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreWriteTopology.java index 719c47459..8a1d8c2f2 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreWriteTopology.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreWriteTopology.java @@ -17,8 +17,13 @@ package org.apache.flink.streaming.api.connector.sink2; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.connector.sink2.Sink; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface WithPreWriteTopology<InputT> extends Sink<InputT>, SupportsPreWriteTopology<InputT> {} diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java index e4f457374..ff1a27611 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java @@ -17,6 +17,12 @@ package org.apache.flink.streaming.api.functions.sink; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface SinkFunction<IN> extends org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<IN> {} diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java index 127ab3cc9..c45677998 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java @@ -17,15 +17,18 @@ package org.apache.flink.streaming.api.functions.source; -import org.apache.flink.annotation.Public; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.functions.AbstractRichFunction; import org.apache.flink.api.common.functions.OpenContext; import org.apache.flink.configuration.Configuration; import org.apache.flink.streaming.api.functions.source.legacy.ParallelSourceFunction; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ @Deprecated -@Public +@Internal public abstract class RichParallelSourceFunction<OUT> extends AbstractRichFunction implements ParallelSourceFunction<OUT>, SourceFunction<OUT> { private static final long serialVersionUID = 1L; diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java index d61e8a991..6147d72d2 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java @@ -17,6 +17,12 @@ package org.apache.flink.streaming.api.functions.source; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface SourceFunction<T> extends org.apache.flink.streaming.api.functions.source.legacy.SourceFunction<T> {} diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java index 34aaac426..0cc855d45 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java @@ -17,6 +17,12 @@ package org.apache.flink.streaming.api.operators; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ +import org.apache.flink.annotation.Internal; + +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public interface YieldingOperatorFactory<OUT> extends org.apache.flink.streaming.api.operators.legacy.YieldingOperatorFactory<OUT> {} diff --git a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/table/api/ValidationException.java b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/table/api/ValidationException.java index fc6a8e37c..20cc03305 100644 --- a/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/table/api/ValidationException.java +++ b/flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/table/api/ValidationException.java @@ -17,12 +17,15 @@ package org.apache.flink.table.api; -import org.apache.flink.annotation.PublicEvolving; +import org.apache.flink.annotation.Internal; import javax.annotation.Nullable; -/** Compatibility adapter to add class that was present in Flink 1.20 but removed in Flink 2.2. */ -@PublicEvolving +/** + * Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer + * that allows Flink CDC to work across different Flink versions. + */ +@Internal public class ValidationException extends RuntimeException { public ValidationException(String message) {
