[FLINK-28795][hive] Fix unstable test in HiveDialectQueryITCase

This closes apache#20569.
liuyongvs · Aug 15, 2022 · 662f9de · 662f9de
1 parent 9b50ff5
commit 662f9de
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectQueryITCase.java b/...connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectQueryITCase.java
@@ -726,11 +726,11 @@ public void testLoadData() throws Exception {
     }
 
     @Test
-    public void testBoolComparison() {
+    public void testBoolComparison() throws Exception {
         tableEnv.executeSql("CREATE TABLE tbool (id int, a int, b string, c boolean)");
         try {
-            tableEnv.executeSql(
-                    "insert into tbool values (1, 1, '12', true), (2, 1, '0.4', false)");
+            tableEnv.executeSql("insert into tbool values (1, 1, '12', true), (2, 1, '0.4', false)")
+                    .await();
             // test compare boolean with numeric/string type
             List<Row> results =
                     CollectionUtil.iteratorToList(