github-forks
/
flink-cdc-connectors
mirror of https://github.com/ververica/flink-cdc-connectors.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source
pull/3291/head
Xie Yi 9 months ago committed by GitHub
parent f61f0f44bd
commit 002b16ed4e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File

2
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/TiDBTestBase.java → flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java
Unescape Escape View File

@ -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;

4
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorITCase.java → flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBConnectorITCase.java
Unescape Escape View File

@ -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;

4
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBConnectorRegionITCase.java → flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBConnectorRegionITCase.java
Unescape Escape View File

@ -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;

4
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/table/TiDBTableSourceFactoryTest.java → flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSourceFactoryTest.java
Unescape Escape View File

@ -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;
Write Preview
Loading…
Cancel
Save