EDIT: changed table name in testAssignTableWithPrimaryKeyWithChunkKey…

…ColumnNotInPrimaryKey
apache · Jul 14, 2024 · dc64490 · dc64490
1 parent f42f809
commit dc64490
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...rg/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java b/...rg/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java
@@ -442,12 +442,12 @@ public void testAssignTableWithPrimaryKeyWithChunkKeyColumnNotInPrimaryKey() {
         String tableWithoutPrimaryKey = "customers";
         List<String> expected =
                 Arrays.asList(
-                        "customers_no_pk null [user_5]",
-                        "customers_no_pk [user_5] [user_9]",
-                        "customers_no_pk [user_9] [user_13]",
-                        "customers_no_pk [user_13] [user_17]",
-                        "customers_no_pk [user_17] [user_20]",
-                        "customers_no_pk [user_20] null");
+                        "customers null [user_5]",
+                        "customers [user_5] [user_9]",
+                        "customers [user_9] [user_13]",
+                        "customers [user_13] [user_17]",
+                        "customers [user_17] [user_20]",
+                        "customers [user_20] null");
         List<String> splits =
                 getTestAssignSnapshotSplits(
                         customerDatabase,