kaisun2000 commented on issue #1372:
URL: https://github.com/apache/helix/issues/1372#issuecomment-695147635
Note, this is a frequent failure case.
```
// add job 3 back
JobConfig.Builder job = new
JobConfig.Builder().setCommand(MockTask.TASK_COMMAND)
.setTargetResource(WorkflowGenerator.DEFAULT_TGT_DB)
.setTargetPartitionStates(Sets.newHashSet("SLAVE"));
// the name here MUST be unique in order to avoid conflicts with the old
job cached in
// RuntimeJobDag
String newJob = deletedJob2 + "_second";
LOG.info("Enqueuing job: " + newJob);
_driver.enqueueJob(queueName, newJob, job);
currentJobNames.add(newJob);
// Ensure the jobs left are successful completed in the correct order
long preJobFinish = 0;
for (int i = 0; i < currentJobNames.size(); i++) {
String namedSpaceJobName = String.format("%s_%s", queueName,
currentJobNames.get(i));
_driver.pollForJobState(queueName, namedSpaceJobName,
TaskState.COMPLETED); --------> failed here.
JobContext jobContext = _driver.getJobContext(namedSpaceJobName);
long jobStart = jobContext.getStartTime();
Assert.assertTrue(jobStart >= preJobFinish);
preJobFinish = jobContext.getFinishTime();
}
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
