Skip to content

Commit 850bac6

Browse files
committed
Resolve conflicts
1 parent 974c043 commit 850bac6

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ void filterOutdatedSplitInfos() {
6868
0,
6969
false);
7070
String expectedTables = "[catalog1.table1, catalog2.table2]";
71-
Assert.assertEquals(expectedTables, binlogSplit.getTables());
71+
Assertions.assertThat(binlogSplit.getTables()).isEqualTo(expectedTables);
7272

7373
// case 1: only include table1
7474
Tables.TableFilter currentTableFilter = tableId -> tableId.table().equals("table1");
@@ -79,7 +79,7 @@ void filterOutdatedSplitInfos() {
7979
mySqlBinlogSplit.getTableSchemas();
8080
Assertions.assertThat(filterTableSchemas).hasSize(1).containsEntry(tableId1, tableChange1);
8181
String expectedTables1 = "[catalog1.table1]";
82-
Assert.assertEquals(expectedTables1, mySqlBinlogSplit.getTables());
82+
Assertions.assertThat(mySqlBinlogSplit.getTables()).isEqualTo(expectedTables1);
8383

8484
// case 2: include all tables
8585
currentTableFilter = tableId -> tableId.table().startsWith("table");
@@ -92,11 +92,11 @@ void filterOutdatedSplitInfos() {
9292
.containsEntry(tableId1, tableChange1)
9393
.containsEntry(tableId2, tableChange2);
9494
String expectedTables2 = "[catalog1.table1, catalog2.table2]";
95-
Assert.assertEquals(expectedTables2, mySqlBinlogSplit.getTables());
95+
Assertions.assertThat(mySqlBinlogSplit.getTables()).isEqualTo(expectedTables2);
9696
}
9797

9898
@Test
99-
public void testTruncatedTablesForLog() {
99+
void testTruncatedTablesForLog() {
100100
Map<TableId, TableChanges.TableChange> tableSchemas = new HashMap<>();
101101

102102
// mock table1
@@ -145,7 +145,7 @@ public void testTruncatedTablesForLog() {
145145
0,
146146
false);
147147
String expectedTables = "[catalog1.table1, catalog2.table2, catalog3.table3]";
148-
Assert.assertEquals(expectedTables, binlogSplit.getTables());
148+
Assertions.assertThat(binlogSplit.getTables()).isEqualTo(expectedTables);
149149
}
150150

151151
/** A mock implementation for {@link Table} which is used for unit tests. */

0 commit comments

Comments
 (0)