diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/VitessSourceTest.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/VitessSourceTest.java
similarity index 99%
rename from flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/VitessSourceTest.java
rename to flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/VitessSourceTest.java
index 73c4e9aeb..5a76cb47c 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/VitessSourceTest.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/VitessSourceTest.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.vervetica.cdc.connectors.vitess;
+package com.ververica.cdc.connectors.vitess;
 
 import org.apache.flink.api.common.state.BroadcastState;
 import org.apache.flink.api.common.state.KeyedStateStore;
@@ -31,7 +31,6 @@ import org.apache.flink.streaming.util.MockStreamingRuntimeContext;
 import org.apache.flink.util.Collector;
 
 import com.ververica.cdc.connectors.utils.TestSourceContext;
-import com.ververica.cdc.connectors.vitess.VitessSource;
 import com.ververica.cdc.connectors.vitess.config.TabletType;
 import com.ververica.cdc.debezium.DebeziumDeserializationSchema;
 import com.ververica.cdc.debezium.DebeziumSourceFunction;
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/VitessTestBase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/VitessTestBase.java
similarity index 91%
rename from flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/VitessTestBase.java
rename to flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/VitessTestBase.java
index b1afa53ef..38a4de4f8 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/VitessTestBase.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/VitessTestBase.java
@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package com.vervetica.cdc.connectors.vitess;
+package com.ververica.cdc.connectors.vitess;
 
 import org.apache.flink.test.util.AbstractTestBase;
 
-import com.vervetica.cdc.connectors.vitess.container.VitessContainer;
+import com.ververica.cdc.connectors.vitess.container.VitessContainer;
 import org.junit.BeforeClass;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -39,8 +39,6 @@ import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
-import static com.vervetica.cdc.connectors.vitess.container.VitessContainer.GRPC_PORT;
-import static com.vervetica.cdc.connectors.vitess.container.VitessContainer.MYSQL_PORT;
 import static org.junit.Assert.assertNotNull;
 
 /** Basic class for testing Vitess source, this contains a Vitess container. */
@@ -55,7 +53,7 @@ public abstract class VitessTestBase extends AbstractTestBase {
                             .withKeyspace("test")
                             .withUsername("flinkuser")
                             .withPassword("flinkpwd")
-                            .withExposedPorts(MYSQL_PORT, GRPC_PORT)
+                            .withExposedPorts(VitessContainer.MYSQL_PORT, VitessContainer.GRPC_PORT)
                             .withLogConsumer(new Slf4jLogConsumer(LOG));
 
     @BeforeClass
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/container/VitessContainer.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/container/VitessContainer.java
similarity index 98%
rename from flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/container/VitessContainer.java
rename to flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/container/VitessContainer.java
index 23a276b2c..aa15eb22c 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/container/VitessContainer.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/container/VitessContainer.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.vervetica.cdc.connectors.vitess.container;
+package com.ververica.cdc.connectors.vitess.container;
 
 import org.testcontainers.containers.JdbcDatabaseContainer;
 
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/table/VitessConnectorITCase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/table/VitessConnectorITCase.java
similarity index 99%
rename from flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/table/VitessConnectorITCase.java
rename to flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/table/VitessConnectorITCase.java
index 669128912..22494e1d8 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/table/VitessConnectorITCase.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/table/VitessConnectorITCase.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.vervetica.cdc.connectors.vitess.table;
+package com.ververica.cdc.connectors.vitess.table;
 
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.table.api.EnvironmentSettings;
@@ -24,7 +24,7 @@ import org.apache.flink.table.planner.factories.TestValuesTableFactory;
 import org.apache.flink.types.Row;
 import org.apache.flink.util.CloseableIterator;
 
-import com.vervetica.cdc.connectors.vitess.VitessTestBase;
+import com.ververica.cdc.connectors.vitess.VitessTestBase;
 import org.junit.Before;
 import org.junit.Test;
 
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/table/VitessTableFactoryTest.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/table/VitessTableFactoryTest.java
similarity index 97%
rename from flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/table/VitessTableFactoryTest.java
rename to flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/table/VitessTableFactoryTest.java
index c242e9e67..b2d07ecf9 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/vervetica/cdc/connectors/vitess/table/VitessTableFactoryTest.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/com/ververica/cdc/connectors/vitess/table/VitessTableFactoryTest.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.vervetica.cdc.connectors.vitess.table;
+package com.ververica.cdc.connectors.vitess.table;
 
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.configuration.Configuration;
@@ -32,8 +32,6 @@ import org.apache.flink.util.ExceptionUtils;
 
 import com.ververica.cdc.connectors.vitess.config.SchemaAdjustmentMode;
 import com.ververica.cdc.connectors.vitess.config.TabletType;
-import com.ververica.cdc.connectors.vitess.table.VitessTableFactory;
-import com.ververica.cdc.connectors.vitess.table.VitessTableSource;
 import org.junit.Test;
 
 import java.util.ArrayList;
diff --git a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/VitessE2eITCase.java b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/VitessE2eITCase.java
index 01666f4e2..207b050b1 100644
--- a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/VitessE2eITCase.java
+++ b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/VitessE2eITCase.java
@@ -19,8 +19,8 @@ package com.ververica.cdc.connectors.tests;
 import com.ververica.cdc.connectors.tests.utils.FlinkContainerTestEnvironment;
 import com.ververica.cdc.connectors.tests.utils.JdbcProxy;
 import com.ververica.cdc.connectors.tests.utils.TestUtils;
-import com.vervetica.cdc.connectors.vitess.VitessTestBase;
-import com.vervetica.cdc.connectors.vitess.container.VitessContainer;
+import com.ververica.cdc.connectors.vitess.VitessTestBase;
+import com.ververica.cdc.connectors.vitess.container.VitessContainer;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -43,8 +43,8 @@ import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
-import static com.vervetica.cdc.connectors.vitess.container.VitessContainer.GRPC_PORT;
-import static com.vervetica.cdc.connectors.vitess.container.VitessContainer.MYSQL_PORT;
+import static com.ververica.cdc.connectors.vitess.container.VitessContainer.GRPC_PORT;
+import static com.ververica.cdc.connectors.vitess.container.VitessContainer.MYSQL_PORT;
 import static org.junit.Assert.assertNotNull;
 
 /** End-to-end test for Vitess CDC connector. */