nsivabalan commented on code in PR #5501:
URL: https://github.com/apache/hudi/pull/5501#discussion_r871391310
##########
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieMultiWriterTestSuiteJob.java:
##########
@@ -131,11 +133,20 @@ public static void main(String[] args) throws Exception {
AtomicBoolean jobFailed = new AtomicBoolean(false);
AtomicInteger counter = new AtomicInteger(0);
+ List<Long> waitTimes = new ArrayList<>();
+ for (int i = 0;i < jobIndex ;i++) {
+ if (i == 0) {
+ waitTimes.add(0L);
+ } else {
+ // every job after 1st, will start after 1 min + some delta.
+ waitTimes.add(60000L + random.nextInt(10000));
Review Comment:
I don't see a necessity for it. main reason to delay every other job except
first is that, table is instantiated fully before other writers step in. so,
probably we can leave it as if for now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@hudi.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
