Skip to content

Commit 245db2c

Browse files
authored
test: Fix flaky test in TestHoodieClientMultiWriter (#17793)
1 parent 013b49e commit 245db2c

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/TestHoodieClientMultiWriter.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
import org.apache.hudi.common.table.view.FileSystemViewStorageType;
5050
import org.apache.hudi.common.testutils.HoodieTestTable;
5151
import org.apache.hudi.common.testutils.HoodieTestUtils;
52+
import org.apache.hudi.common.testutils.InProcessTimeGenerator;
5253
import org.apache.hudi.common.util.CommitUtils;
5354
import org.apache.hudi.io.util.FileIOUtils;
5455
import org.apache.hudi.common.util.Option;
@@ -703,19 +704,19 @@ public void testMultiWriterWithInsertsToDistinctPartitions(HoodieTableType table
703704

704705
// Create the first commit
705706
SparkRDDWriteClient<?> client = getHoodieWriteClient(cfg);
706-
createCommitWithInsertsForPartition(cfg, client, "000", "001", 100, "2016/03/01");
707+
String firstCommitTime = InProcessTimeGenerator.createNewInstantTime();
708+
createCommitWithInsertsForPartition(cfg, client, "000", firstCommitTime, 100, "2016/03/01");
707709
client.close();
708710
int numConcurrentWriters = 5;
709711
ExecutorService executors = Executors.newFixedThreadPool(numConcurrentWriters);
710712

711713
List<Future<?>> futures = new ArrayList<>(numConcurrentWriters);
712714
for (int loop = 0; loop < numConcurrentWriters; loop++) {
713-
String newCommitTime = "00" + (loop + 2);
714715
String partition = "2016/03/0" + (loop + 2);
715716
futures.add(executors.submit(() -> {
716717
try {
717718
SparkRDDWriteClient<?> writeClient = getHoodieWriteClient(cfg);
718-
createCommitWithInsertsForPartition(cfg, writeClient, "001", newCommitTime, 100, partition);
719+
createCommitWithInsertsForPartition(cfg, writeClient, "001", InProcessTimeGenerator.createNewInstantTime(), 100, partition);
719720
writeClient.close();
720721
} catch (Exception e) {
721722
throw new RuntimeException(e);

0 commit comments

Comments
 (0)