Skip to content

Commit dfb036b

Browse files
author
Seung-Min Lee
committed
FIX: fixed expected in testAssignTableWithPrimaryKeyWithChunkKeyColumnNotInPrimaryKey
1 parent 11c32b4 commit dfb036b

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java

+7-6
Original file line numberDiff line numberDiff line change
@@ -443,12 +443,13 @@ public void testAssignTableWithPrimaryKeyWithChunkKeyColumnNotInPrimaryKey() {
443443
String tableWithoutPrimaryKey = "customers";
444444
List<String> expected =
445445
Arrays.asList(
446-
"customers null [user_5]",
447-
"customers [user_5] [user_9]",
448-
"customers [user_9] [user_13]",
449-
"customers [user_13] [user_17]",
450-
"customers [user_17] [user_20]",
451-
"customers [user_20] null");
446+
"customers null [user_12]",
447+
"customers [user_12] [user_15]",
448+
"customers [user_15] [user_18]",
449+
"customers [user_18] [user_20]",
450+
"customers [user_20] [user_4]",
451+
"customers [user_4] [user_7]",
452+
"customers [user_7] null");
452453
List<String> splits =
453454
getTestAssignSnapshotSplits(
454455
customerDatabase,

0 commit comments

Comments
 (0)