Skip to content

Commit 30b04a9

Browse files
committed
fixed CatalogTableAdapter error
1 parent c08aaab commit 30b04a9

1 file changed

Lines changed: 2 additions & 7 deletions

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSourceFactoryTest.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,12 +21,7 @@
2121
import org.apache.flink.configuration.Configuration;
2222
import org.apache.flink.table.api.DataTypes;
2323
import org.apache.flink.table.api.Schema;
24-
import org.apache.flink.table.catalog.CatalogTable;
25-
import org.apache.flink.table.catalog.Column;
26-
import org.apache.flink.table.catalog.ObjectIdentifier;
27-
import org.apache.flink.table.catalog.ResolvedCatalogTable;
28-
import org.apache.flink.table.catalog.ResolvedSchema;
29-
import org.apache.flink.table.catalog.UniqueConstraint;
24+
import org.apache.flink.table.catalog.*;
3025
import org.apache.flink.table.connector.source.DynamicTableSource;
3126
import org.apache.flink.table.factories.FactoryUtil;
3227

@@ -210,7 +205,7 @@ private static DynamicTableSource createTableSource(
210205
null,
211206
ObjectIdentifier.of("default", "default", "t1"),
212207
new ResolvedCatalogTable(
213-
CatalogTable.of(
208+
CatalogTableAdapter.of(
214209
Schema.newBuilder().fromResolvedSchema(schema).build(),
215210
"mock source",
216211
new ArrayList<>(),

0 commit comments

Comments
 (0)