[MINOR] Fix flaky test in ITTestHoodieDataSource (apache#7134)

onehouseinc · Dec 14, 2022 · ac2d7d3 · ac2d7d3
1 parent 924e150
commit ac2d7d3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java b/...ink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java
@@ -400,7 +400,8 @@ void testStreamReadMorTableWithCompactionPlan() throws Exception {
         .end();
     streamTableEnv.executeSql(hoodieTableDDL);
 
-    streamTableEnv.executeSql("insert into t1 select * from source");
+    String insertInto = "insert into t1 select * from source";
+    execInsertSql(streamTableEnv, insertInto);
 
     List<Row> result = execSelectSql(streamTableEnv, "select * from t1", 10);
     final String expected = "["