[HUDI-4188] Fix flaky ITTestDataSTreamWrite.testWriteCopyOnWrite (apa…

…che#5749)
yihua · Jun 7, 2022 · 834b13a · 834b13a
1 parent 3a8fb97
commit 834b13a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java b/...flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
@@ -102,7 +102,7 @@ public void testWriteCopyOnWrite(String indexType) throws Exception {
     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