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
The following commit(s) were added to refs/heads/FLINK-38729-2 by this push:
new c4247b266 Update java doc.
c4247b266 is described below
commit c4247b266c73c68ae7de2c3485bc59401c2c0091
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) {
