Skip to content

Commit de9ebb3

Browse files
committed
Resolve conflicts
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
1 parent 9d76b76 commit de9ebb3

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -947,7 +947,7 @@ public void testBinlogOffsetCompareWithSnapshotAndBinlogPhase() throws Exception
947947
List<SourceRecord> sourceRecords =
948948
pollRecordsFromReader(binlogReader, RecordUtils::isDataChangeRecord);
949949
MYSQL_CONTAINER_NOGTID.stop();
950-
assertTrue(sourceRecords.isEmpty());
950+
Assertions.assertThat(sourceRecords).isEmpty();
951951
}
952952

953953
private BinlogSplitReader createBinlogReader(MySqlSourceConfig sourceConfig) {

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,8 +57,6 @@
5757
import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ENABLED;
5858
import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.SCAN_SNAPSHOT_FETCH_SIZE;
5959
import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.USE_LEGACY_JSON_FORMAT;
60-
import static org.junit.Assert.assertEquals;
61-
import static org.junit.Assert.assertTrue;
6260

6361
/** Test for {@link MySqlTableSource} created by {@link MySqlTableSourceFactory}. */
6462
class MySqlTableSourceFactoryTest {

0 commit comments

Comments
 (0)