From 22c45a7704cf4d5ec6fb56ee7cc1bf17d826315d Mon Sep 17 00:00:00 2001 From: Danny Chan Date: Mon, 6 Jun 2022 12:12:48 +0800 Subject: [PATCH] [HUDI-4188] Fix flaky ITTestDataSTreamWrite.testWriteCopyOnWrite (#5749) --- .../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 b9deb43a9..9c5eeeeb5 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