[FLINK-34584][cdc][build] Rename package from com.ververica to org.apache.flink

This closes #3089.

README.md

@@ -117,8 +117,8 @@ Include following Maven dependency (available through Maven Central):
 ```java
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
 
 public class MySqlSourceExample {
   public static void main(String[] args) throws Exception {

docs/content/connectors/db2-cdc.md

@@ -225,7 +225,7 @@ _Note: the mechanism of `scan.startup.mode` option relying on Debezium's `snapsh
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
 
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 
 public class Db2SourceExample {
   public static void main(String[] args) throws Exception {

docs/content/connectors/mongodb-cdc(ZH).md

@@ -438,8 +438,8 @@ MongoDB CDC 连接器也可以是一个数据流源。 你可以创建 SourceFun
 ```java
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mongodb.MongoDBSource;
+import org.apache.flink.cdc.connectors.mongodb.MongoDBSource;
 
 public class MongoDBSourceExample {
     public static void main(String[] args) throws Exception {
@@ -466,8 +466,8 @@ MongoDB CDC 增量连接器（2.3.0 之后）可以使用，如下所示：
 ```java
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.connectors.mongodb.source.MongoDBSource;
+import org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 
 public class MongoDBIncrementalSourceExample {
     public static void main(String[] args) throws Exception {

docs/content/connectors/mongodb-cdc.md

@@ -448,8 +448,8 @@ The MongoDB CDC connector can also be a DataStream source. You can create a Sour
 ```java
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mongodb.MongoDBSource;
+import org.apache.flink.cdc.connectors.mongodb.MongoDBSource;
 
 public class MongoDBSourceExample {
     public static void main(String[] args) throws Exception {
@@ -476,8 +476,8 @@ The MongoDB CDC incremental connector (after 2.3.0) can be used as the following
 ```java
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.connectors.mongodb.source.MongoDBSource;
+import org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 
 public class MongoDBIncrementalSourceExample {
     public static void main(String[] args) throws Exception {

docs/content/connectors/mysql-cdc(ZH).md

@@ -652,8 +652,8 @@ CREATE TABLE mysql_source (...) WITH (
 ```java
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
 
 public class MySqlSourceExample {
   public static void main(String[] args) throws Exception {

docs/content/connectors/mysql-cdc.md

@@ -666,8 +666,8 @@ could fail as the Debezium reader keeps the current latest table schema internal
 ```java
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
 
 public class MySqlSourceExample {
   public static void main(String[] args) throws Exception {

docs/content/connectors/oceanbase-cdc(ZH).md

@@ -443,10 +443,10 @@ import org.apache.flink.table.data.RowData;
 import org.apache.flink.table.runtime.typeutils.InternalTypeInfo;
 import org.apache.flink.table.types.logical.RowType;
 
-import com.ververica.cdc.connectors.oceanbase.OceanBaseSource;
+import org.apache.flink.cdc.connectors.oceanbase.OceanBaseSource;
-import com.ververica.cdc.connectors.oceanbase.source.RowDataOceanBaseDeserializationSchema;
+import org.apache.flink.cdc.connectors.oceanbase.source.RowDataOceanBaseDeserializationSchema;
-import com.ververica.cdc.connectors.oceanbase.table.OceanBaseDeserializationSchema;
+import org.apache.flink.cdc.connectors.oceanbase.table.OceanBaseDeserializationSchema;
-import com.ververica.cdc.connectors.oceanbase.table.StartupMode;
+import org.apache.flink.cdc.connectors.oceanbase.table.StartupMode;
 
 import java.time.ZoneId;
 import java.util.Arrays;

docs/content/connectors/oceanbase-cdc.md

@@ -451,10 +451,10 @@ import org.apache.flink.table.data.RowData;
 import org.apache.flink.table.runtime.typeutils.InternalTypeInfo;
 import org.apache.flink.table.types.logical.RowType;
 
-import com.ververica.cdc.connectors.oceanbase.OceanBaseSource;
+import org.apache.flink.cdc.connectors.oceanbase.OceanBaseSource;
-import com.ververica.cdc.connectors.oceanbase.source.RowDataOceanBaseDeserializationSchema;
+import org.apache.flink.cdc.connectors.oceanbase.source.RowDataOceanBaseDeserializationSchema;
-import com.ververica.cdc.connectors.oceanbase.table.OceanBaseDeserializationSchema;
+import org.apache.flink.cdc.connectors.oceanbase.table.OceanBaseDeserializationSchema;
-import com.ververica.cdc.connectors.oceanbase.table.StartupMode;
+import org.apache.flink.cdc.connectors.oceanbase.table.StartupMode;
 
 import java.time.ZoneId;
 import java.util.Arrays;

docs/content/connectors/oracle-cdc.md

@@ -509,10 +509,10 @@ The Oracle CDC connector can also be a DataStream source. There are two modes fo
 #### Incremental Snapshot based DataStream (Experimental)
 
 ```java
-import com.ververica.cdc.connectors.base.options.StartupOptions;
+import org.apache.flink.cdc.connectors.base.options.StartupOptions;
-import com.ververica.cdc.connectors.base.source.jdbc.JdbcIncrementalSource;
+import org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource;
-import com.ververica.cdc.connectors.oracle.source.OracleSourceBuilder;
+import org.apache.flink.cdc.connectors.oracle.source.OracleSourceBuilder;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 
@@ -561,8 +561,8 @@ public class OracleParallelSourceExample {
 ```java
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.oracle.OracleSource;
+import org.apache.flink.cdc.connectors.oracle.OracleSource;
 
 public class OracleSourceExample {
   public static void main(String[] args) throws Exception {

docs/content/connectors/postgres-cdc.md

@@ -444,10 +444,10 @@ The Postgres CDC connector can also be a DataStream source. There are two modes
 #### Incremental Snapshot based DataStream (Experimental)
 
 ```java
-import com.ververica.cdc.connectors.base.source.jdbc.JdbcIncrementalSource;
+import org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource;
-import com.ververica.cdc.connectors.postgres.source.PostgresSourceBuilder;
+import org.apache.flink.cdc.connectors.postgres.source.PostgresSourceBuilder;
-import com.ververica.cdc.debezium.DebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.DebeziumDeserializationSchema;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 
@@ -495,8 +495,8 @@ public class PostgresParallelSourceExample {
 ```java
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.postgres.PostgreSQLSource;
+import org.apache.flink.cdc.connectors.postgres.PostgreSQLSource;
 
 public class PostgreSQLSourceExample {
   public static void main(String[] args) throws Exception {

docs/content/connectors/sqlserver-cdc.md

@@ -342,8 +342,8 @@ The SQLServer CDC connector can also be a DataStream source. You can create a So
 ```java
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.sqlserver.SqlServerSource;
+import org.apache.flink.cdc.connectors.sqlserver.SqlServerSource;
 
 public class SqlServerSourceExample {
   public static void main(String[] args) throws Exception {
@@ -373,10 +373,10 @@ The SQLServer CDC incremental connector (after 2.4.0) can be used as the followi
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 
-import com.ververica.cdc.connectors.base.options.StartupOptions;
+import org.apache.flink.cdc.connectors.base.options.StartupOptions;
-import com.ververica.cdc.connectors.sqlserver.source.SqlServerSourceBuilder;
+import org.apache.flink.cdc.connectors.sqlserver.source.SqlServerSourceBuilder;
-import com.ververica.cdc.connectors.sqlserver.source.SqlServerSourceBuilder.SqlServerIncrementalSource;
+import org.apache.flink.cdc.connectors.sqlserver.source.SqlServerSourceBuilder.SqlServerIncrementalSource;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 
 public class SqlServerIncrementalSourceExample {
     public static void main(String[] args) throws Exception {

docs/content/connectors/tidb-cdc.md

@@ -241,10 +241,10 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
 import org.apache.flink.util.Collector;
 
-import com.ververica.cdc.connectors.tidb.TDBSourceOptions;
+import org.apache.flink.cdc.connectors.tidb.TDBSourceOptions;
-import com.ververica.cdc.connectors.tidb.TiDBSource;
+import org.apache.flink.cdc.connectors.tidb.TiDBSource;
-import com.ververica.cdc.connectors.tidb.TiKVChangeEventDeserializationSchema;
+import org.apache.flink.cdc.connectors.tidb.TiKVChangeEventDeserializationSchema;
-import com.ververica.cdc.connectors.tidb.TiKVSnapshotEventDeserializationSchema;
+import org.apache.flink.cdc.connectors.tidb.TiKVSnapshotEventDeserializationSchema;
 import org.tikv.kvproto.Cdcpb;
 import org.tikv.kvproto.Kvrpcpb;
 

docs/content/connectors/vitess-cdc.md

@@ -224,8 +224,8 @@ The Incremental Reading feature of Vitess CDC Source only exposes in SQL current
 ```java
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.vitess.VitessSource;
+import org.apache.flink.cdc.connectors.vitess.VitessSource;
 
 public class VitessSourceExample {
   public static void main(String[] args) throws Exception {

docs/content/overview/cdc-connectors.md

@@ -124,8 +124,8 @@ Include following Maven dependency (available through Maven Central):
 
 ```java
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
 
 public class MySqlBinlogSourceExample {
   public static void main(String[] args) throws Exception {

docs/content/quickstart/datastream-api-package-guidance.md

@@ -182,35 +182,35 @@ flink 1.17.2  flink mysql cdc 2.4.2
                                 <relocation>
                                     <pattern>org.apache.kafka</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.org.apache.kafka
+                                        org.apache.flink.cdc.connectors.shaded.org.apache.kafka
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>org.antlr</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.org.antlr
+                                        org.apache.flink.cdc.connectors.shaded.org.antlr
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.fasterxml</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.com.fasterxml
+                                        org.apache.flink.cdc.connectors.shaded.com.fasterxml
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.google</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.com.google
+                                        org.apache.flink.cdc.connectors.shaded.com.google
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.esri.geometry</pattern>
-                                    <shadedPattern>com.ververica.cdc.connectors.shaded.com.esri.geometry</shadedPattern>
+                                    <shadedPattern>org.apache.flink.cdc.connectors.shaded.com.esri.geometry</shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.zaxxer</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.com.zaxxer
+                                        org.apache.flink.cdc.connectors.shaded.com.zaxxer
                                     </shadedPattern>
                                 </relocation>
                             </relocations>
@@ -233,8 +233,8 @@ package com.ververica.flink.cdc;
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 
 public class CdcTest {
     public static void main(String[] args) throws Exception {

docs/content/快速上手/datastream-api-package-guidance-zh.md

@@ -182,35 +182,35 @@ flink 1.17.2  flink mysql cdc 2.4.2
                                 <relocation>
                                     <pattern>org.apache.kafka</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.org.apache.kafka
+                                        org.apache.flink.cdc.connectors.shaded.org.apache.kafka
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>org.antlr</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.org.antlr
+                                        org.apache.flink.cdc.connectors.shaded.org.antlr
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.fasterxml</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.com.fasterxml
+                                        org.apache.flink.cdc.connectors.shaded.com.fasterxml
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.google</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.com.google
+                                        org.apache.flink.cdc.connectors.shaded.com.google
                                     </shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.esri.geometry</pattern>
-                                    <shadedPattern>com.ververica.cdc.connectors.shaded.com.esri.geometry</shadedPattern>
+                                    <shadedPattern>org.apache.flink.cdc.connectors.shaded.com.esri.geometry</shadedPattern>
                                 </relocation>
                                 <relocation>
                                     <pattern>com.zaxxer</pattern>
                                     <shadedPattern>
-                                        com.ververica.cdc.connectors.shaded.com.zaxxer
+                                        org.apache.flink.cdc.connectors.shaded.com.zaxxer
                                     </shadedPattern>
                                 </relocation>
                             </relocations>
@@ -233,8 +233,8 @@ package com.ververica.flink.cdc;
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
 
 public class CdcTest {
     public static void main(String[] args) throws Exception {

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java

@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli;
+package org.apache.flink.cdc.cli;
-
+
-import com.ververica.cdc.cli.parser.PipelineDefinitionParser;
+import org.apache.flink.cdc.cli.parser.PipelineDefinitionParser;
-import com.ververica.cdc.cli.parser.YamlPipelineDefinitionParser;
+import org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser;
-import com.ververica.cdc.cli.utils.FlinkEnvironmentUtils;
+import org.apache.flink.cdc.cli.utils.FlinkEnvironmentUtils;
-import com.ververica.cdc.common.annotation.VisibleForTesting;
+import org.apache.flink.cdc.common.annotation.VisibleForTesting;
-import com.ververica.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.common.configuration.Configuration;
-import com.ververica.cdc.composer.PipelineComposer;
+import org.apache.flink.cdc.composer.PipelineComposer;
-import com.ververica.cdc.composer.PipelineExecution;
+import org.apache.flink.cdc.composer.PipelineExecution;
-import com.ververica.cdc.composer.definition.PipelineDef;
+import org.apache.flink.cdc.composer.definition.PipelineDef;
 
 import java.nio.file.Path;
 import java.util.List;

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java

@@ -15,13 +15,14 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli;
+package org.apache.flink.cdc.cli;
+
+import org.apache.flink.cdc.cli.utils.ConfigurationUtils;
+import org.apache.flink.cdc.cli.utils.FlinkEnvironmentUtils;
+import org.apache.flink.cdc.common.annotation.VisibleForTesting;
+import org.apache.flink.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.composer.PipelineExecution;
 
-import com.ververica.cdc.cli.utils.ConfigurationUtils;
-import com.ververica.cdc.cli.utils.FlinkEnvironmentUtils;
-import com.ververica.cdc.common.annotation.VisibleForTesting;
-import com.ververica.cdc.common.configuration.Configuration;
-import com.ververica.cdc.composer.PipelineExecution;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.DefaultParser;

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontendOptions.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli;
+package org.apache.flink.cdc.cli;
 
 import org.apache.commons.cli.Option;
 import org.apache.commons.cli.Options;

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/PipelineDefinitionParser.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli.parser;
+package org.apache.flink.cdc.cli.parser;
 
-import com.ververica.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.common.configuration.Configuration;
-import com.ververica.cdc.composer.definition.PipelineDef;
+import org.apache.flink.cdc.composer.definition.PipelineDef;
 
 import java.nio.file.Path;
 

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java

@@ -15,26 +15,26 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli.parser;
+package org.apache.flink.cdc.cli.parser;
+
+import org.apache.flink.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.composer.definition.PipelineDef;
+import org.apache.flink.cdc.composer.definition.RouteDef;
+import org.apache.flink.cdc.composer.definition.SinkDef;
+import org.apache.flink.cdc.composer.definition.SourceDef;
 
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.type.TypeReference;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
 
-import com.ververica.cdc.common.configuration.Configuration;
-import com.ververica.cdc.composer.definition.PipelineDef;
-import com.ververica.cdc.composer.definition.RouteDef;
-import com.ververica.cdc.composer.definition.SinkDef;
-import com.ververica.cdc.composer.definition.SourceDef;
-
 import java.nio.file.Path;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
 
-import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
+import static org.apache.flink.cdc.common.utils.Preconditions.checkNotNull;
 
 /** Parser for converting YAML formatted pipeline definition to {@link PipelineDef}. */
 public class YamlPipelineDefinitionParser implements PipelineDefinitionParser {

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/ConfigurationUtils.java

@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli.utils;
+package org.apache.flink.cdc.cli.utils;
+
+import org.apache.flink.cdc.common.configuration.Configuration;
 
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.type.TypeReference;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
 
-import com.ververica.cdc.common.configuration.Configuration;
-
 import java.io.FileNotFoundException;
 import java.nio.file.Files;
 import java.nio.file.Path;

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli.utils;
+package org.apache.flink.cdc.cli.utils;
 
-import com.ververica.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.common.configuration.Configuration;
-import com.ververica.cdc.composer.flink.FlinkPipelineComposer;
+import org.apache.flink.cdc.composer.flink.FlinkPipelineComposer;
 
 import java.nio.file.Path;
 import java.util.List;

flink-cdc-cli/src/test/java/org/apache/flink/cdc/cli/CliFrontendTest.java

@@ -15,13 +15,14 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli;
+package org.apache.flink.cdc.cli;
+
+import org.apache.flink.cdc.composer.PipelineComposer;
+import org.apache.flink.cdc.composer.PipelineExecution;
+import org.apache.flink.cdc.composer.definition.PipelineDef;
 
 import org.apache.flink.shaded.guava31.com.google.common.io.Resources;
 
-import com.ververica.cdc.composer.PipelineComposer;
-import com.ververica.cdc.composer.PipelineExecution;
-import com.ververica.cdc.composer.definition.PipelineDef;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.DefaultParser;
 import org.apache.commons.cli.Options;

flink-cdc-cli/src/test/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParserTest.java

@@ -15,16 +15,17 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.cli.parser;
+package org.apache.flink.cdc.cli.parser;
+
+import org.apache.flink.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.composer.definition.PipelineDef;
+import org.apache.flink.cdc.composer.definition.RouteDef;
+import org.apache.flink.cdc.composer.definition.SinkDef;
+import org.apache.flink.cdc.composer.definition.SourceDef;
 
 import org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableMap;
 import org.apache.flink.shaded.guava31.com.google.common.io.Resources;
 
-import com.ververica.cdc.common.configuration.Configuration;
-import com.ververica.cdc.composer.definition.PipelineDef;
-import com.ververica.cdc.composer.definition.RouteDef;
-import com.ververica.cdc.composer.definition.SinkDef;
-import com.ververica.cdc.composer.definition.SourceDef;
 import org.junit.jupiter.api.Test;
 
 import java.net.URL;
@@ -32,11 +33,11 @@ import java.nio.file.Paths;
 import java.util.Arrays;
 import java.util.Collections;
 
-import static com.ververica.cdc.common.pipeline.PipelineOptions.PIPELINE_LOCAL_TIME_ZONE;
+import static org.apache.flink.cdc.common.pipeline.PipelineOptions.PIPELINE_LOCAL_TIME_ZONE;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.AssertionsForClassTypes.assertThatThrownBy;
 
-/** Unit test for {@link YamlPipelineDefinitionParser}. */
+/** Unit test for {@link org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser}. */
 class YamlPipelineDefinitionParserTest {
 
     @Test

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Experimental.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.annotation;
+package org.apache.flink.cdc.common.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Internal.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.annotation;
+package org.apache.flink.cdc.common.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Public.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.annotation;
+package org.apache.flink.cdc.common.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/PublicEvolving.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.annotation;
+package org.apache.flink.cdc.common.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/VisibleForTesting.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.annotation;
+package org.apache.flink.cdc.common.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java

@@ -15,17 +15,16 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration;
+package org.apache.flink.cdc.common.configuration;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.configuration.description.Description;
+import org.apache.flink.cdc.common.configuration.description.Description;
+import org.apache.flink.cdc.common.utils.Preconditions;
 
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.stream.Stream;
 
-import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
-
 /**
  * A {@code ConfigOption} describes a configuration parameter. It encapsulates the configuration
  * key, deprecated older versions of the key, and an optional default value for the configuration
@@ -98,11 +97,11 @@ public class ConfigOption<T> {
             T defaultValue,
             boolean isList,
             FallbackKey... fallbackKeys) {
-        this.key = checkNotNull(key);
+        this.key = Preconditions.checkNotNull(key);
         this.description = description;
         this.defaultValue = defaultValue;
         this.fallbackKeys = fallbackKeys == null || fallbackKeys.length == 0 ? EMPTY : fallbackKeys;
-        this.clazz = checkNotNull(clazz);
+        this.clazz = Preconditions.checkNotNull(clazz);
         this.isList = isList;
     }
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java

@@ -15,18 +15,17 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration;
+package org.apache.flink.cdc.common.configuration;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.configuration.description.Description;
+import org.apache.flink.cdc.common.configuration.description.Description;
+import org.apache.flink.cdc.common.utils.Preconditions;
 
 import java.time.Duration;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
 
-import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
-
 /**
  * {@code ConfigOptions} are used to build a {@link ConfigOption}. The option is typically built in
  * one of the following pattern:
@@ -75,7 +74,7 @@ public class ConfigOptions {
      * @return The builder for the config option with the given key.
      */
     public static OptionBuilder key(String key) {
-        checkNotNull(key);
+        Preconditions.checkNotNull(key);
         return new OptionBuilder(key);
     }
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration;
+package org.apache.flink.cdc.common.configuration;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -26,10 +26,10 @@ import java.util.Map;
 import java.util.Optional;
 import java.util.function.BiFunction;
 
-import static com.ververica.cdc.common.configuration.ConfigurationUtils.canBePrefixMap;
+import static org.apache.flink.cdc.common.configuration.ConfigurationUtils.canBePrefixMap;
-import static com.ververica.cdc.common.configuration.ConfigurationUtils.containsPrefixMap;
+import static org.apache.flink.cdc.common.configuration.ConfigurationUtils.containsPrefixMap;
-import static com.ververica.cdc.common.configuration.ConfigurationUtils.convertToPropertiesPrefixed;
+import static org.apache.flink.cdc.common.configuration.ConfigurationUtils.convertToPropertiesPrefixed;
-import static com.ververica.cdc.common.configuration.ConfigurationUtils.removePrefixMap;
+import static org.apache.flink.cdc.common.configuration.ConfigurationUtils.removePrefixMap;
 
 /** Lightweight configuration object which stores key/value pairs. */
 public class Configuration implements java.io.Serializable, Cloneable {

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration;
+package org.apache.flink.cdc.common.configuration;
 
-import com.ververica.cdc.common.utils.TimeUtils;
+import org.apache.flink.cdc.common.utils.TimeUtils;
 
 import java.time.Duration;
 import java.util.Arrays;
@@ -26,8 +26,6 @@ import java.util.Locale;
 import java.util.Map;
 import java.util.stream.Collectors;
 
-import static com.ververica.cdc.common.configuration.StructuredOptionsSplitter.escapeWithSingleQuote;
-
 /** Utility class for {@link Configuration} related helper functions. */
 public class ConfigurationUtils {
 
@@ -140,7 +138,10 @@ public class ConfigurationUtils {
         } else if (o instanceof List) {
             return ((List<?>) o)
                     .stream()
-                            .map(e -> escapeWithSingleQuote(convertToString(e), ";"))
+                            .map(
+                                    e ->
+                                            StructuredOptionsSplitter.escapeWithSingleQuote(
+                                                    convertToString(e), ";"))
                             .collect(Collectors.joining(";"));
         } else if (o instanceof Map) {
             return ((Map<?, ?>) o)
@@ -148,11 +149,13 @@ public class ConfigurationUtils {
                             .map(
                                     e -> {
                                         String escapedKey =
-                                                escapeWithSingleQuote(e.getKey().toString(), ":");
+                                                StructuredOptionsSplitter.escapeWithSingleQuote(
+                                                        e.getKey().toString(), ":");
                                         String escapedValue =
-                                                escapeWithSingleQuote(e.getValue().toString(), ":");
+                                                StructuredOptionsSplitter.escapeWithSingleQuote(
+                                                        e.getValue().toString(), ":");
 
-                                        return escapeWithSingleQuote(
+                                        return StructuredOptionsSplitter.escapeWithSingleQuote(
                                                 escapedKey + ":" + escapedValue, ",");
                                     })
                             .collect(Collectors.joining(","));

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/FallbackKey.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration;
+package org.apache.flink.cdc.common.configuration;
 
 /** A key with FallbackKeys will fall back to the FallbackKeys if it itself is not configured. */
 public class FallbackKey {

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java

@@ -15,16 +15,15 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration;
+package org.apache.flink.cdc.common.configuration;
 
-import com.ververica.cdc.common.annotation.Internal;
+import org.apache.flink.cdc.common.annotation.Internal;
+import org.apache.flink.cdc.common.utils.Preconditions;
 
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 
-import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
-
 /** Helper class for splitting a string on a given delimiter with quoting logic. */
 @Internal
 class StructuredOptionsSplitter {
@@ -48,7 +47,7 @@ class StructuredOptionsSplitter {
      * @return a list of splits
      */
     static List<String> splitEscaped(String string, char delimiter) {
-        List<Token> tokens = tokenize(checkNotNull(string), delimiter);
+        List<Token> tokens = tokenize(Preconditions.checkNotNull(string), delimiter);
         return processTokens(tokens);
     }
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/BlockElement.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /** Part of description that represents a block e.g. some text, linebreak or a list. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/Description.java

@@ -15,17 +15,15 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.configuration.ConfigOption;
 
 import java.util.ArrayList;
 import java.util.List;
 
-/**
+/** Description for {@link ConfigOption}. Allows providing multiple rich formats. */
- * Description for {@link com.ververica.cdc.common.configuration.ConfigOption}. Allows providing
- * multiple rich formats.
- */
 @PublicEvolving
 public class Description {
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/DescriptionElement.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /** Part of a {@link Description} that can be converted into String representation. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/Formatter.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 import java.util.EnumSet;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/HtmlFormatter.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
 import java.util.EnumSet;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/InlineElement.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /** Part of description that represents an element inside a block e.g. a link. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LineBreakElement.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /** Represents a line break in the {@link Description}. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LinkElement.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /** Element that represents a link in the {@link Description}. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/ListElement.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 import java.util.Arrays;
 import java.util.List;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/TextElement.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.configuration.description;
+package org.apache.flink.cdc.common.configuration.description;
 
-import org.apache.flink.shaded.guava31.com.google.common.base.Strings;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.shaded.guava31.com.google.common.base.Strings;
 
 import java.util.Arrays;
 import java.util.Collections;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java

@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.ArrayType;
+import org.apache.flink.cdc.common.types.ArrayType;
-import com.ververica.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataType;
 
 import javax.annotation.Nullable;
 
 import java.io.Serializable;
 
-import static com.ververica.cdc.common.types.DataTypeChecks.getFieldCount;
+import static org.apache.flink.cdc.common.types.DataTypeChecks.getFieldCount;
-import static com.ververica.cdc.common.types.DataTypeChecks.getPrecision;
+import static org.apache.flink.cdc.common.types.DataTypeChecks.getPrecision;
-import static com.ververica.cdc.common.types.DataTypeChecks.getScale;
+import static org.apache.flink.cdc.common.types.DataTypeChecks.getScale;
 
 /**
  * Base interface of an internal data structure representing data of {@link ArrayType}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/DecimalData.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.DecimalType;
+import org.apache.flink.cdc.common.types.DecimalType;
 
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
@@ -27,7 +27,7 @@ import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.math.RoundingMode;
 
-import static com.ververica.cdc.common.utils.Preconditions.checkArgument;
+import static org.apache.flink.cdc.common.utils.Preconditions.checkArgument;
 
 /**
  * An internal data structure representing data of {@link DecimalType}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java

@@ -15,10 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
+
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.types.ArrayType;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.ArrayType;
 import org.apache.commons.lang3.ArrayUtils;
 
 import java.util.Arrays;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericMapData.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.MapType;
+import org.apache.flink.cdc.common.types.MapType;
 
 import java.util.Map;
 import java.util.Objects;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/LocalZonedTimestampData.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.LocalZonedTimestampType;
+import org.apache.flink.cdc.common.types.LocalZonedTimestampType;
-import com.ververica.cdc.common.utils.Preconditions;
+import org.apache.flink.cdc.common.utils.Preconditions;
 
 import java.time.Instant;
 import java.time.LocalDate;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/MapData.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.MapType;
+import org.apache.flink.cdc.common.types.MapType;
 
 /**
  * Base interface of an internal data structure representing data of {@link MapType}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java

@@ -15,18 +15,18 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataType;
 
 import javax.annotation.Nullable;
 
 import java.io.Serializable;
 
-import static com.ververica.cdc.common.types.DataTypeChecks.getFieldCount;
+import static org.apache.flink.cdc.common.types.DataTypeChecks.getFieldCount;
-import static com.ververica.cdc.common.types.DataTypeChecks.getPrecision;
+import static org.apache.flink.cdc.common.types.DataTypeChecks.getPrecision;
-import static com.ververica.cdc.common.types.DataTypeChecks.getScale;
+import static org.apache.flink.cdc.common.types.DataTypeChecks.getScale;
 
 /**
  * Class {@code RecordData} describes the data of changed record (i.e. row) in the external system.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/StringData.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.CharType;
+import org.apache.flink.cdc.common.types.CharType;
-import com.ververica.cdc.common.types.VarCharType;
+import org.apache.flink.cdc.common.types.VarCharType;
 
 /** An internal data structure representing data of {@link CharType} and {@link VarCharType}. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.TimestampType;
+import org.apache.flink.cdc.common.types.TimestampType;
-import com.ververica.cdc.common.utils.Preconditions;
+import org.apache.flink.cdc.common.utils.Preconditions;
 
 import java.sql.Timestamp;
 import java.time.LocalDate;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ZonedTimestampData.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data;
+package org.apache.flink.cdc.common.data;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.ZonedTimestampType;
+import org.apache.flink.cdc.common.types.ZonedTimestampType;
-import com.ververica.cdc.common.utils.Preconditions;
+import org.apache.flink.cdc.common.utils.Preconditions;
 
 import java.sql.Timestamp;
 import java.time.Instant;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryFormat.java

@@ -15,12 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
 
+import org.apache.flink.cdc.common.annotation.Internal;
 import org.apache.flink.core.memory.MemorySegment;
 
-import com.ververica.cdc.common.annotation.Internal;
-
 /** Binary format spanning {@link MemorySegment}s. */
 @Internal
 public interface BinaryFormat {

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryRecordData.java

@@ -15,31 +15,29 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
-
+
+import org.apache.flink.cdc.common.annotation.Internal;
+import org.apache.flink.cdc.common.data.ArrayData;
+import org.apache.flink.cdc.common.data.DecimalData;
+import org.apache.flink.cdc.common.data.LocalZonedTimestampData;
+import org.apache.flink.cdc.common.data.MapData;
+import org.apache.flink.cdc.common.data.RecordData;
+import org.apache.flink.cdc.common.data.StringData;
+import org.apache.flink.cdc.common.data.TimestampData;
+import org.apache.flink.cdc.common.data.ZonedTimestampData;
+import org.apache.flink.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataTypeRoot;
+import org.apache.flink.cdc.common.types.DecimalType;
+import org.apache.flink.cdc.common.types.LocalZonedTimestampType;
+import org.apache.flink.cdc.common.types.TimestampType;
+import org.apache.flink.cdc.common.types.ZonedTimestampType;
+import org.apache.flink.cdc.common.utils.Preconditions;
 import org.apache.flink.core.memory.MemorySegment;
 import org.apache.flink.core.memory.MemorySegmentFactory;
 
-import com.ververica.cdc.common.annotation.Internal;
-import com.ververica.cdc.common.data.ArrayData;
-import com.ververica.cdc.common.data.DecimalData;
-import com.ververica.cdc.common.data.LocalZonedTimestampData;
-import com.ververica.cdc.common.data.MapData;
-import com.ververica.cdc.common.data.RecordData;
-import com.ververica.cdc.common.data.StringData;
-import com.ververica.cdc.common.data.TimestampData;
-import com.ververica.cdc.common.data.ZonedTimestampData;
-import com.ververica.cdc.common.types.DataType;
-import com.ververica.cdc.common.types.DecimalType;
-import com.ververica.cdc.common.types.LocalZonedTimestampType;
-import com.ververica.cdc.common.types.TimestampType;
-import com.ververica.cdc.common.types.ZonedTimestampType;
-
 import java.nio.ByteOrder;
 
-import static com.ververica.cdc.common.types.DataTypeRoot.DECIMAL;
-import static com.ververica.cdc.common.utils.Preconditions.checkArgument;
-
 /**
  * An implementation of {@link RecordData} which is backed by {@link MemorySegment} instead of
  * Object. It can significantly reduce the serialization/deserialization of Java objects.
@@ -110,14 +108,14 @@ public final class BinaryRecordData extends BinarySection implements RecordData,
     }
 
     public static boolean isMutable(DataType type) {
-        return isInFixedLengthPart(type) || type.getTypeRoot() == DECIMAL;
+        return isInFixedLengthPart(type) || type.getTypeRoot() == DataTypeRoot.DECIMAL;
     }
 
     private final int arity;
     private final int nullBitsSizeInBytes;
 
     public BinaryRecordData(int arity) {
-        checkArgument(arity >= 0);
+        Preconditions.checkArgument(arity >= 0);
         this.arity = arity;
         this.nullBitsSizeInBytes = calculateBitSetWidthInBytes(arity);
     }

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java

@@ -15,13 +15,12 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
 
+import org.apache.flink.cdc.common.annotation.Internal;
+import org.apache.flink.cdc.common.utils.Preconditions;
 import org.apache.flink.core.memory.MemorySegment;
 
-import com.ververica.cdc.common.annotation.Internal;
-import com.ververica.cdc.common.utils.Preconditions;
-
 /** A basic implementation of {@link BinaryFormat} which describe a section of memory. */
 @Internal
 public class BinarySection implements BinaryFormat {

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java

@@ -15,23 +15,22 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
-
+
+import org.apache.flink.cdc.common.annotation.Internal;
+import org.apache.flink.cdc.common.data.DecimalData;
+import org.apache.flink.cdc.common.data.LocalZonedTimestampData;
+import org.apache.flink.cdc.common.data.RecordData;
+import org.apache.flink.cdc.common.data.StringData;
+import org.apache.flink.cdc.common.data.TimestampData;
 import org.apache.flink.core.memory.DataOutputView;
 import org.apache.flink.core.memory.MemorySegment;
 
-import com.ververica.cdc.common.annotation.Internal;
-import com.ververica.cdc.common.data.DecimalData;
-import com.ververica.cdc.common.data.LocalZonedTimestampData;
-import com.ververica.cdc.common.data.RecordData;
-import com.ververica.cdc.common.data.StringData;
-import com.ververica.cdc.common.data.TimestampData;
-
 import java.io.IOException;
 import java.nio.ByteOrder;
 
-import static com.ververica.cdc.common.data.binary.BinaryFormat.HIGHEST_FIRST_BIT;
+import static org.apache.flink.cdc.common.data.binary.BinaryFormat.HIGHEST_FIRST_BIT;
-import static com.ververica.cdc.common.data.binary.BinaryFormat.HIGHEST_SECOND_TO_EIGHTH_BIT;
+import static org.apache.flink.cdc.common.data.binary.BinaryFormat.HIGHEST_SECOND_TO_EIGHTH_BIT;
 import static org.apache.flink.core.memory.MemoryUtils.UNSAFE;
 
 /** Utilities for binary data segments which heavily uses {@link MemorySegment}. */

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java

@@ -15,23 +15,20 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
 
 import org.apache.flink.api.common.typeutils.TypeSerializer;
+import org.apache.flink.cdc.common.annotation.Internal;
+import org.apache.flink.cdc.common.data.StringData;
+import org.apache.flink.cdc.common.utils.Preconditions;
+import org.apache.flink.cdc.common.utils.StringUtf8Utils;
 import org.apache.flink.core.memory.MemorySegment;
 import org.apache.flink.core.memory.MemorySegmentFactory;
 
-import com.ververica.cdc.common.annotation.Internal;
-import com.ververica.cdc.common.data.StringData;
-import com.ververica.cdc.common.utils.StringUtf8Utils;
-
 import javax.annotation.Nonnull;
 
 import java.util.Arrays;
 
-import static com.ververica.cdc.common.data.binary.BinarySegmentUtils.getBytes;
-import static com.ververica.cdc.common.utils.Preconditions.checkArgument;
-
 /**
  * A lazily binary implementation of {@link StringData} which is backed by {@link MemorySegment}s
  * and {@link String}.
@@ -111,7 +108,8 @@ public final class BinaryStringData extends LazyBinaryFormat<String> implements
     @Override
     public byte[] toBytes() {
         ensureMaterialized();
-        return getBytes(binarySection.segments, binarySection.offset, binarySection.sizeInBytes);
+        return BinarySegmentUtils.getBytes(
+                binarySection.segments, binarySection.offset, binarySection.sizeInBytes);
     }
 
     @Override
@@ -261,7 +259,7 @@ public final class BinaryStringData extends LazyBinaryFormat<String> implements
             needCompare = Math.min(Math.min(sizeOfFirst1, sizeOfFirst2), len);
         }
 
-        checkArgument(needCompare == len);
+        Preconditions.checkArgument(needCompare == len);
 
         return binarySection.sizeInBytes - other.binarySection.sizeInBytes;
     }

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/LazyBinaryFormat.java

@@ -15,13 +15,12 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
 
 import org.apache.flink.api.common.typeutils.TypeSerializer;
+import org.apache.flink.cdc.common.annotation.Internal;
 import org.apache.flink.core.memory.MemorySegment;
 
-import com.ververica.cdc.common.annotation.Internal;
-
 import java.io.IOException;
 
 /**

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/MurmurHashUtils.java

@@ -15,12 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
 
+import org.apache.flink.cdc.common.annotation.Internal;
 import org.apache.flink.core.memory.MemorySegment;
 
-import com.ververica.cdc.common.annotation.Internal;
-
 import static org.apache.flink.core.memory.MemoryUtils.UNSAFE;
 
 /** Murmur Hash. This is inspired by Guava's Murmur3_32HashFunction. */

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/NullAwareGetters.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.data.binary;
+package org.apache.flink.cdc.common.data.binary;
 
-import com.ververica.cdc.common.annotation.Internal;
+import org.apache.flink.cdc.common.annotation.Internal;
 
 /** Provides null related getters. */
 @Internal

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AddColumnEvent.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.schema.Column;
+import org.apache.flink.cdc.common.schema.Column;
 
 import javax.annotation.Nullable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterColumnTypeEvent.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataType;
 
 import java.util.Map;
 import java.util.Objects;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/ChangeEvent.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /**
  * Class {@code ChangeEvent} represents the change events of external systems, including {@link

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/CreateTableEvent.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.schema.Schema;
+import org.apache.flink.cdc.common.schema.Schema;
-import com.ververica.cdc.common.source.DataSource;
+import org.apache.flink.cdc.common.source.DataSource;
 
 import java.util.Objects;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.data.RecordData;
+import org.apache.flink.cdc.common.data.RecordData;
 
 import java.io.Serializable;
 import java.util.Collections;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropColumnEvent.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 import java.util.List;
 import java.util.Objects;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/Event.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /**
  * Class {@code Event} is the super interface defines the events of external systems flowing into

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/EventDeserializer.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 import java.io.Serializable;
 import java.util.List;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/FlushEvent.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
 import java.util.Objects;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/OperationType.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /**
  * Enum {@code OperationType} describes the type of operation that the data change event reports.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/RenameColumnEvent.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
 import java.util.Map;
 import java.util.Objects;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEvent.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 import java.io.Serializable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.event;
+package org.apache.flink.cdc.common.event;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 import javax.annotation.Nullable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSinkFactory.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.factories;
+package org.apache.flink.cdc.common.factories;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.sink.DataSink;
+import org.apache.flink.cdc.common.sink.DataSink;
 
 /**
  * A factory to create {@link DataSink} instances. See also {@link Factory} for more information.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSourceFactory.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.factories;
+package org.apache.flink.cdc.common.factories;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.source.DataSource;
+import org.apache.flink.cdc.common.source.DataSource;
 
 /**
  * A factory to create {@link DataSource} instances. See also {@link Factory} for more information.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.factories;
+package org.apache.flink.cdc.common.factories;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.configuration.ConfigOption;
+import org.apache.flink.cdc.common.configuration.ConfigOption;
-import com.ververica.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.common.configuration.Configuration;
 
 import java.util.Set;
 
@@ -30,8 +30,8 @@ import java.util.Set;
  * <p>A factory is uniquely identified by {@link Class} and {@link #identifier()}.
  *
  * <p>The list of available factories is discovered using Java's Service Provider Interfaces (SPI).
- * Classes that implement this interface can be added to {@code
+ * Classes that implement this interface can be added to {@code META_INF/services/Factory} in JAR
- * META_INF/services/com.ververica.cdc.common.factories.Factory} in JAR files.
+ * files.
  *
  * <p>Every factory declares a set of required and optional options. This information will not be
  * used during discovery but is helpful when generating documentation and performing validation. A

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/FactoryHelper.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.factories;
+package org.apache.flink.cdc.common.factories;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.configuration.Configuration;
+import org.apache.flink.cdc.common.configuration.Configuration;
 
 /** A helper for working with {@link Factory}. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java

@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.pipeline;
+package org.apache.flink.cdc.common.pipeline;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.configuration.ConfigOption;
+import org.apache.flink.cdc.common.configuration.ConfigOption;
-import com.ververica.cdc.common.configuration.ConfigOptions;
+import org.apache.flink.cdc.common.configuration.ConfigOptions;
-import com.ververica.cdc.common.configuration.description.Description;
+import org.apache.flink.cdc.common.configuration.description.Description;
-import com.ververica.cdc.common.configuration.description.ListElement;
+import org.apache.flink.cdc.common.configuration.description.ListElement;
 
-import static com.ververica.cdc.common.configuration.description.TextElement.text;
+import static org.apache.flink.cdc.common.configuration.description.TextElement.text;
 
 /** Predefined pipeline configuration options. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/SchemaChangeBehavior.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.pipeline;
+package org.apache.flink.cdc.common.pipeline;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /** Behavior for handling schema changes. */
 @PublicEvolving

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Column.java

@@ -15,18 +15,18 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.schema;
+package org.apache.flink.cdc.common.schema;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataType;
 
 import javax.annotation.Nullable;
 
 import java.io.Serializable;
 import java.util.Objects;
 
-import static com.ververica.cdc.common.utils.EncodingUtils.escapeIdentifier;
+import static org.apache.flink.cdc.common.utils.EncodingUtils.escapeIdentifier;
-import static com.ververica.cdc.common.utils.EncodingUtils.escapeSingleQuotes;
+import static org.apache.flink.cdc.common.utils.EncodingUtils.escapeSingleQuotes;
 
 /**
  * Representation of a column in a {@link Schema}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/MetadataColumn.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.schema;
+package org.apache.flink.cdc.common.schema;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataType;
 
 import javax.annotation.Nullable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/PhysicalColumn.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.schema;
+package org.apache.flink.cdc.common.schema;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataType;
 
 import javax.annotation.Nullable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java

@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.schema;
+package org.apache.flink.cdc.common.schema;
-
+
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.types.DataField;
+import org.apache.flink.cdc.common.types.DataField;
-import com.ververica.cdc.common.types.DataType;
+import org.apache.flink.cdc.common.types.DataType;
-import com.ververica.cdc.common.types.DataTypeRoot;
+import org.apache.flink.cdc.common.types.DataTypeRoot;
-import com.ververica.cdc.common.types.DataTypes;
+import org.apache.flink.cdc.common.types.DataTypes;
-import com.ververica.cdc.common.types.RowType;
+import org.apache.flink.cdc.common.types.RowType;
-import com.ververica.cdc.common.utils.Preconditions;
+import org.apache.flink.cdc.common.utils.Preconditions;
 
 import javax.annotation.Nullable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Selectors.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.schema;
+package org.apache.flink.cdc.common.schema;
 
-import com.ververica.cdc.common.event.TableId;
+import org.apache.flink.cdc.common.event.TableId;
-import com.ververica.cdc.common.utils.Predicates;
+import org.apache.flink.cdc.common.utils.Predicates;
 
 import java.util.ArrayList;
 import java.util.Iterator;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/TableFilter.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.schema;
+package org.apache.flink.cdc.common.schema;
 
-import com.ververica.cdc.common.event.TableId;
+import org.apache.flink.cdc.common.event.TableId;
 
 import java.util.function.Predicate;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DataSink.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.sink;
+package org.apache.flink.cdc.common.sink;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /**
  * {@code DataSink} is used to write change data to external system and apply metadata changes to

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/EventSinkProvider.java

@@ -15,13 +15,12 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.sink;
+package org.apache.flink.cdc.common.sink;
 
 import org.apache.flink.api.connector.sink2.Sink;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 import org.apache.flink.streaming.api.functions.sink.SinkFunction;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
-
 /**
  * A marker interface used to provide an event sink for writing change events to external systems.
  * We can reuse exiting Flink {@link Sink} and Flink {@link SinkFunction} implementation, and we can

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkFunctionProvider.java

@@ -15,13 +15,12 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.sink;
+package org.apache.flink.cdc.common.sink;
 
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.event.Event;
 import org.apache.flink.streaming.api.functions.sink.SinkFunction;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.event.Event;
-
 /**
  * {@code FlinkSinkFunctionProvider} is used to provide a Flink {@link SinkFunction} for writing
  * events to external systems.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkProvider.java

@@ -15,12 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.sink;
+package org.apache.flink.cdc.common.sink;
 
 import org.apache.flink.api.connector.sink2.Sink;
-
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.event.Event;
-import com.ververica.cdc.common.event.Event;
 
 /**
  * {@code FlinkSinkProvider} is used to provide a Flink {@link Sink} for writing events to external

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.sink;
+package org.apache.flink.cdc.common.sink;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.event.SchemaChangeEvent;
+import org.apache.flink.cdc.common.event.SchemaChangeEvent;
 
 import java.io.Serializable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/DataSource.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.source;
+package org.apache.flink.cdc.common.source;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 
 /**
  * {@code DataSource} is used to access metadata and read change data from external systems. It can

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/EventSourceProvider.java

@@ -15,13 +15,12 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.source;
+package org.apache.flink.cdc.common.source;
 
 import org.apache.flink.api.connector.source.Source;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
-
 /**
  * A marker interface used to provide an event source for reading events from external systems. We
  * can reuse exiting Flink {@link Source} and Flink {@link SourceFunction} implementation, and we

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceFunctionProvider.java

@@ -15,13 +15,12 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.source;
+package org.apache.flink.cdc.common.source;
 
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.event.Event;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.event.Event;
-
 /**
  * {@code FlinkSourceFunctionProvider} is used to provide a Flink {@link SourceFunction} for reading
  * events from external systems.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceProvider.java

@@ -15,12 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.source;
+package org.apache.flink.cdc.common.source;
 
 import org.apache.flink.api.connector.source.Source;
-
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.event.Event;
-import com.ververica.cdc.common.event.Event;
 
 /**
  * {@code FlinkSourceProvider} is used to provide a Flink {@link Source} for reading events from

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/MetadataAccessor.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.source;
+package org.apache.flink.cdc.common.source;
 
-import com.ververica.cdc.common.annotation.PublicEvolving;
+import org.apache.flink.cdc.common.annotation.PublicEvolving;
-import com.ververica.cdc.common.event.TableId;
+import org.apache.flink.cdc.common.event.TableId;
-import com.ververica.cdc.common.schema.Schema;
+import org.apache.flink.cdc.common.schema.Schema;
 
 import javax.annotation.Nullable;
 

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/ParsingException.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.ververica.cdc.common.text;
+package org.apache.flink.cdc.common.text;
 
 /** An exception representing a problem during parsing of text. */
 public class ParsingException extends RuntimeException {