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

fengjian428 · Apr 5, 2023 · f9d3b47 · f9d3b47
1 parent 2b1754f
commit f9d3b47
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
@@ -436,7 +436,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 = "["