[FLINK-35244][cdc-connector][tidb] Correct the package for flink-conn…

…ector-tidb-cdc test
Jiabao-Sun · May 6, 2024 · 002b16e · 002b16e
1 parent f61f0f4
commit 002b16e
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 8 deletions.
diff --git a/...he/flink/cdc/connectors/TiDBTestBase.java → ...ink/cdc/connectors/tidb/TiDBTestBase.java b/...he/flink/cdc/connectors/TiDBTestBase.java → ...ink/cdc/connectors/tidb/TiDBTestBase.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.cdc.connectors;
+package org.apache.flink.cdc.connectors.tidb;
 
 import org.apache.flink.test.util.AbstractTestBase;
 

diff --git a/...connectors/table/TiDBConnectorITCase.java → ...ctors/tidb/table/TiDBConnectorITCase.java b/...connectors/table/TiDBConnectorITCase.java → ...ctors/tidb/table/TiDBConnectorITCase.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.cdc.connectors.table;
+package org.apache.flink.cdc.connectors.tidb.table;
 
-import org.apache.flink.cdc.connectors.TiDBTestBase;
+import org.apache.flink.cdc.connectors.tidb.TiDBTestBase;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.table.api.EnvironmentSettings;
 import org.apache.flink.table.api.TableResult;

diff --git a/...tors/table/TiDBConnectorRegionITCase.java → ...tidb/table/TiDBConnectorRegionITCase.java b/...tors/table/TiDBConnectorRegionITCase.java → ...tidb/table/TiDBConnectorRegionITCase.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.cdc.connectors.table;
+package org.apache.flink.cdc.connectors.tidb.table;
 
-import org.apache.flink.cdc.connectors.TiDBTestBase;
+import org.apache.flink.cdc.connectors.tidb.TiDBTestBase;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.table.api.EnvironmentSettings;
 import org.apache.flink.table.api.TableResult;

diff --git a/...ors/table/TiDBTableSourceFactoryTest.java → ...idb/table/TiDBTableSourceFactoryTest.java b/...ors/table/TiDBTableSourceFactoryTest.java → ...idb/table/TiDBTableSourceFactoryTest.java
@@ -15,10 +15,8 @@
  * limitations under the License.
  */
 
-package org.apache.flink.cdc.connectors.table;
+package org.apache.flink.cdc.connectors.tidb.table;
 
-import org.apache.flink.cdc.connectors.tidb.table.StartupOptions;
-import org.apache.flink.cdc.connectors.tidb.table.TiDBTableSource;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.api.Schema;