fix ut

oceanbase · Jan 25, 2024 · c999f43 · c999f43
1 parent 8c972ad
commit c999f43
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...ector-oceanbase/src/test/java/com/oceanbase/connector/flink/OceanBaseConnectorITCase.java b/...ector-oceanbase/src/test/java/com/oceanbase/connector/flink/OceanBaseConnectorITCase.java
@@ -138,11 +138,18 @@ public void testMultipleTableSink() throws Exception {
                                         tableFullNameA)),
                         new OceanBaseTestData(
                                 database,
-                                tableA,
+                                tableB,
                                 SchemaChangeRecord.Type.CREATE,
                                 String.format(
                                         "CREATE TABLE %s (b int(10) primary key, b1 varchar(20))",
                                         tableFullNameB)),
+                        new OceanBaseTestData(
+                                database,
+                                tableC,
+                                SchemaChangeRecord.Type.CREATE,
+                                String.format(
+                                        "CREATE TABLE %s (c int(10), c1 varchar(20))",
+                                        tableFullNameC)),
                         new OceanBaseTestData(
                                 "test",
                                 tableA,