From c999f4375fe209b557e08078cc9c10e3859ee584 Mon Sep 17 00:00:00 2001
From: He Wang <wanghechn@qq.com>
Date: Thu, 25 Jan 2024 15:52:25 +0800
Subject: [PATCH] fix ut

---
 .../connector/flink/OceanBaseConnectorITCase.java        | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/flink-connector-oceanbase/src/test/java/com/oceanbase/connector/flink/OceanBaseConnectorITCase.java b/flink-connector-oceanbase/src/test/java/com/oceanbase/connector/flink/OceanBaseConnectorITCase.java
index 1e2213db..ed0264b0 100644
--- a/flink-connector-oceanbase/src/test/java/com/oceanbase/connector/flink/OceanBaseConnectorITCase.java
+++ b/flink-connector-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,