[hotfix][FLINK-19183][hive] Fix compile error by TableEnvHiveConnecto…

…rITCase.testTransactionalTable
aghyad · Sep 10, 2020 · e319820 · e319820
1 parent cbda1f9
commit e319820
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ctor-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java b/...ctor-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
@@ -581,12 +581,12 @@ private void testTransactionalTable(boolean batch) {
 			hiveShell.execute("create table db1.dest (x string,y string) clustered by (x) into 3 buckets stored as orc tblproperties ('transactional'='true')");
 			List<Exception> exceptions = new ArrayList<>();
 			try {
-				TableEnvUtil.execInsertSqlAndWaitResult(tableEnv, "insert into db1.src select * from db1.dest");
+				tableEnv.executeSql("insert into db1.src select * from db1.dest").await();
 			} catch (Exception e) {
 				exceptions.add(e);
 			}
 			try {
-				TableEnvUtil.execInsertSqlAndWaitResult(tableEnv, "insert into db1.dest select * from db1.src");
+				tableEnv.executeSql("insert into db1.dest select * from db1.src").await();
 			} catch (Exception e) {
 				exceptions.add(e);
 			}