Skip to content

Commit bebb8fb

Browse files
beryllw王俊博
authored andcommitted
fix unit test
1 parent 9197b9b commit bebb8fb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -955,7 +955,7 @@ private void testMySqlParallelSource(
955955
+ " 'scan.incremental.snapshot.chunk.size' = '100',"
956956
+ " 'scan.incremental.snapshot.backfill.skip' = '%s',"
957957
+ " 'server-time-zone' = 'UTC',"
958-
+ " 'scan.incremental.snapshot.assign-ending-first.enabled' = '%s',"
958+
+ " 'scan.incremental.snapshot.assign-ending-chunk-first.enabled' = '%s',"
959959
+ " 'server-id' = '%s'"
960960
+ " %s"
961961
+ ")",

0 commit comments

Comments
 (0)