From 739ddc7cdd840649a00d63b4c34d4ccb63d81821 Mon Sep 17 00:00:00 2001 From: Danny Chan Date: Thu, 25 Aug 2022 16:10:31 +0800 Subject: [PATCH] [HUDI-4713] Fix flaky ITTestHoodieDataSource#testAppendWrite (#6490) --- .../java/org/apache/hudi/table/ITTestHoodieDataSource.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 66af39e4c1c1..e59a393fd303 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 @@ -1015,8 +1015,8 @@ void testBulkInsertNonPartitionedTable() { void testAppendWrite(boolean clustering) { TableEnvironment tableEnv = streamTableEnv; // csv source - String csvSourceDDL = TestConfigurations.getCsvSourceDDL("csv_source", "test_source_5.data"); - tableEnv.executeSql(csvSourceDDL); + String sourceDDL = TestConfigurations.getFileSourceDDL("source"); + tableEnv.executeSql(sourceDDL); String hoodieTableDDL = sql("hoodie_sink") .option(FlinkOptions.PATH, tempFile.getAbsolutePath()) @@ -1025,7 +1025,7 @@ void testAppendWrite(boolean clustering) { .end(); tableEnv.executeSql(hoodieTableDDL); - String insertInto = "insert into hoodie_sink select * from csv_source"; + String insertInto = "insert into hoodie_sink select * from source"; execInsertSql(tableEnv, insertInto); List result1 = CollectionUtil.iterableToList(