You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2022/08/25 08:10:38 UTC
[hudi] branch master updated: [HUDI-4713] Fix flaky ITTestHoodieDataSource#testAppendWrite (#6490)
This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new e46647341c [HUDI-4713] Fix flaky ITTestHoodieDataSource#testAppendWrite (#6490)
e46647341c is described below
commit e46647341c21762ab96a8d6906e2ec2568ee9409
Author: Danny Chan <yu...@gmail.com>
AuthorDate: Thu Aug 25 16:10:31 2022 +0800
[HUDI-4713] Fix flaky ITTestHoodieDataSource#testAppendWrite (#6490)
---
.../src/test/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 66af39e4c1..e59a393fd3 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 @@ public class ITTestHoodieDataSource extends AbstractTestBase {
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 @@ public class ITTestHoodieDataSource extends AbstractTestBase {
.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<Row> result1 = CollectionUtil.iterableToList(