[FLINK-34358] Fix some tests that failed in Flink 1.19

wanglijie95 · web-flow · commit 5d6bd2e12bcd · 2024-02-20T13:30:26.000+01:00
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
@@ -99,10 +99,10 @@ void testDataTypeValidate(TestItem testItem) {
         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");
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -99,10 +99,10 @@ void testDataTypeValidate(TestItem testItem) {`
`99`	`99`	`tEnv.executeSql(sqlDDL);`
`100`	`100`
`101`	`101`	`if (testItem.expectError != null) {`
`102`		`- assertThatThrownBy(() -> tEnv.sqlQuery("SELECT * FROM T"))`
	`102`	`+ assertThatThrownBy(() -> tEnv.executeSql("SELECT * FROM T"))`
`103`	`103`	`.satisfies(anyCauseMatches(testItem.expectError));`
`104`	`104`	`} else {`
`105`		`- tEnv.sqlQuery("SELECT * FROM T");`
	`105`	`+ tEnv.executeSql("SELECT * FROM T");`
`106`	`106`	`}`
`107`	`107`	`}`
`108`	`108`