Skip to content

Commit d0b2fe3

Browse files
authored
[hotfix][source-connector/mysql] Fix conflicts after flink version bumped to 1.19 (#3748)
1 parent 3a2d799 commit d0b2fe3

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/table/MySqlConnectorShardingTableITCase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ public void testShardingTablesWithTinyInt1() throws Exception {
196196
new String[] {
197197
"+I[1, 1]", "+I[2, 0]", "+I[3, 1]", "+I[4, 0]", "+I[5, 1]", "+I[6, 0]",
198198
};
199-
List<String> actual = TestValuesTableFactory.getResults("sink");
199+
List<String> actual = TestValuesTableFactory.getResultsAsStrings("sink");
200200
assertEqualsInAnyOrder(Arrays.asList(expected), actual);
201201
result.getJobClient().get().cancel().get();
202202
}

0 commit comments

Comments
 (0)