From dc644909c915a91d44edf0a7a237206877d0b50c Mon Sep 17 00:00:00 2001 From: Seung-Min Lee Date: Sun, 14 Jul 2024 18:33:39 +0900 Subject: [PATCH] EDIT: changed table name in testAssignTableWithPrimaryKeyWithChunkKeyColumnNotInPrimaryKey --- .../assigners/MySqlSnapshotSplitAssignerTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java index d7da2c6150b..aadc327e950 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java @@ -442,12 +442,12 @@ public void testAssignTableWithPrimaryKeyWithChunkKeyColumnNotInPrimaryKey() { String tableWithoutPrimaryKey = "customers"; List 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 splits = getTestAssignSnapshotSplits( customerDatabase,