(flink-cdc) branch master updated: [hotfix][source-connector/mysql] Fix conflicts after flink version bumped to 1.19 (#3748)

[ruanhang1993]

This is an automated email from the ASF dual-hosted git repository.

ruanhang1993 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new d0b2fe38a [hotfix][source-connector/mysql] Fix conflicts after flink 
version bumped to 1.19 (#3748)
d0b2fe38a is described below

commit d0b2fe38a2fbdb792092ed82289ac560d2e39f59
Author: Leonard Xu <xbjt...@gmail.com>
AuthorDate: Wed Nov 20 03:00:26 2024 -0800

    [hotfix][source-connector/mysql] Fix conflicts after flink version bumped 
to 1.19 (#3748)
---
 .../cdc/connectors/mysql/table/MySqlConnectorShardingTableITCase.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorShardingTableITCase.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorShardingTableITCase.java
index 9297465dc..8ee1e9f28 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorShardingTableITCase.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorShardingTableITCase.java
@@ -196,7 +196,7 @@ public class MySqlConnectorShardingTableITCase extends 
MySqlSourceTestBase {
                 new String[] {
                     "+I[1, 1]", "+I[2, 0]", "+I[3, 1]", "+I[4, 0]", "+I[5, 
1]", "+I[6, 0]",
                 };
-        List<String> actual = TestValuesTableFactory.getResults("sink");
+        List<String> actual = 
TestValuesTableFactory.getResultsAsStrings("sink");
         assertEqualsInAnyOrder(Arrays.asList(expected), actual);
         result.getJobClient().get().cancel().get();
     }