Skip to content

Commit c1a8f33

Browse files
author
王俊博
committed
fix unit test
1 parent a4cc11f commit c1a8f33

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@ public void testAssignMySqlBinlogSplitAfterAllSnapshotSplitsFinished() {
119119
configuration, DEFAULT_PARALLELISM, checkpoint, enumeratorContext);
120120

121121
// step 2. Get the MySqlBinlogSplit after all snapshot splits finished
122+
assigner.open();
122123
Optional<MySqlSplit> binlogSplit = assigner.getNext();
123124
MySqlBinlogSplit mySqlBinlogSplit = binlogSplit.get().asBinlogSplit();
124125

0 commit comments

Comments
 (0)