This is an automated email from the ASF dual-hosted git repository.
jiabaosun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 002b16ed4 [FLINK-35244][cdc-connector][tidb] Correct the package for
flink-connector-tidb-cdc test
002b16ed4 is described below
commit 002b16ed4e155b01374040ff302b7536d9c41245
Author: Xie Yi <[email protected]>
AuthorDate: Mon May 6 09:39:25 2024 +0800
[FLINK-35244][cdc-connector][tidb] Correct the package for
flink-connector-tidb-cdc test
---
.../java/org/apache/flink/cdc/connectors/{ => tidb}/TiDBTestBase.java | 2 +-
.../flink/cdc/connectors/{ => tidb}/table/TiDBConnectorITCase.java | 4 ++--
.../cdc/connectors/{ => tidb}/table/TiDBConnectorRegionITCase.java | 4 ++--
.../cdc/connectors/{ => tidb}/table/TiDBTableSourceFactoryTest.java | 4 +---
4 files changed, 6 insertions(+), 8 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/TiDBTestBase.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java
similarity index 99%
rename from
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/TiDBTestBase.java
rename to
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java
index d9266757b..7c32539e4 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/TiDBTestBase.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/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/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorITCase.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBConnectorITCase.java
similarity index 99%
rename from
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorITCase.java
rename to
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBConnectorITCase.java
index 3f7e73cf0..a492367a4 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorITCase.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/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/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorRegionITCase.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBConnectorRegionITCase.java
similarity index 98%
rename from
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorRegionITCase.java
rename to
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBConnectorRegionITCase.java
index 373224640..766b4b77e 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorRegionITCase.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/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/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBTableSourceFactoryTest.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSourceFactoryTest.java
similarity index 97%
rename from
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBTableSourceFactoryTest.java
rename to
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSourceFactoryTest.java
index 2b3428f1b..ea882c7e8 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBTableSourceFactoryTest.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/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;
