(flink-connector-jdbc) branch main updated: [FLINK-34358] Fix some tests that failed in Flink 1.19

[snuyanzin]

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

snuyanzin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git


The following commit(s) were added to refs/heads/main by this push:
     new 5d6bd2e1 [FLINK-34358] Fix some tests that failed in Flink 1.19
5d6bd2e1 is described below

commit 5d6bd2e12bcdd488e182c53a9f97d5685744e6a7
Author: Lijie Wang <wangdachui9...@gmail.com>
AuthorDate: Tue Feb 20 20:30:26 2024 +0800

    [FLINK-34358] Fix some tests that failed in Flink 1.19
---
 .../org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeTest.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeTest.java
 
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeTest.java
index de51b731..7ff4d6c4 100644
--- 
a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeTest.java
+++ 
b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeTest.java
@@ -99,10 +99,10 @@ public class JdbcDialectTypeTest {
         tEnv.executeSql(sqlDDL);
 
         if (testItem.expectError != null) {
-            assertThatThrownBy(() -> tEnv.sqlQuery("SELECT * FROM T"))
+            assertThatThrownBy(() -> tEnv.executeSql("SELECT * FROM T"))
                     .satisfies(anyCauseMatches(testItem.expectError));
         } else {
-            tEnv.sqlQuery("SELECT * FROM T");
+            tEnv.executeSql("SELECT * FROM T");
         }
     }