From ac2d7d302d4095fe45ac0f4f393e76e7f6c7fedb Mon Sep 17 00:00:00 2001
From: Alexander Trushev <trushev.alex@gmail.com>
Date: Sat, 5 Nov 2022 00:34:08 +0700
Subject: [PATCH] [MINOR] Fix flaky test in ITTestHoodieDataSource (#7134)

---
 .../java/org/apache/hudi/table/ITTestHoodieDataSource.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java
index 49fb82709a30..fecd0a3eaf3f 100644
--- a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java
+++ b/hudi-flink-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 = "["