Skip to content

Commit de91480

Browse files
committed
[FLINK-38618][base] Fix reassign stream split cause offset error when startup mode is latest-offset and taskManager failover
1 parent a323292 commit de91480

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-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@
6363
import static org.apache.flink.table.api.DataTypes.STRING;
6464
import static org.apache.flink.table.catalog.Column.physical;
6565
import static org.apache.flink.util.Preconditions.checkState;
66-
import static org.junit.Assert.assertFalse;
66+
import static org.junit.jupiter.api.Assertions.assertFalse;
6767
import static org.testcontainers.containers.MSSQLServerContainer.MS_SQL_SERVER_PORT;
6868

6969
/** IT tests for {@link SqlServerSourceBuilder.SqlServerIncrementalSource}. */

0 commit comments

Comments
 (0)