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 22c45a7704 [HUDI-4188] Fix flaky
ITTestDataSTreamWrite.testWriteCopyOnWrite (#5749)
22c45a7704 is described below
commit 22c45a7704cf4d5ec6fb56ee7cc1bf17d826315d
Author: Danny Chan <[email protected]>
AuthorDate: Mon Jun 6 12:12:48 2022 +0800
[HUDI-4188] Fix flaky ITTestDataSTreamWrite.testWriteCopyOnWrite (#5749)
---
.../src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
index b9deb43a97..9c5eeeeb5a 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
@@ -102,7 +102,7 @@ public class ITTestDataStreamWrite extends TestLogger {
conf.setString(FlinkOptions.INDEX_KEY_FIELD, "id");
conf.setBoolean(FlinkOptions.PRE_COMBINE,true);
- testWriteToHoodie(conf, "cow_write", 1, EXPECTED);
+ testWriteToHoodie(conf, "cow_write", 2, EXPECTED);
}
@Test