Skip to content

Commit a33ef41

Browse files
committed
DS-2259:
TaskedSpaceBasedStep: solve duplicate tasks start issue. Signed-off-by: mchrza <maximilian.chrzan@here.com>
1 parent ea6b082 commit a33ef41

1 file changed

Lines changed: 9 additions & 3 deletions

File tree

xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport/TaskedSpaceBasedStep.java

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -399,13 +399,19 @@ private ValidationException handleWebClientException(String message, WebClientEx
399399
*/
400400
private void startInitialTasks() throws TooManyResourcesClaimed,
401401
QueryBuildingException, WebClientException, SQLException, InvalidGeometryException {
402+
List<TaskProgress<I>> claimedInitialTasks = new ArrayList<>();
402403

404+
//Claim the initial task set
403405
for (int i = 0; i < threadCount; i++) {
404-
TaskProgress taskProgressAndTaskItem = getTaskProgressAndNextTaskItem();
405-
if(taskProgressAndTaskItem.getTaskId() == -1)
406+
TaskProgress<I> taskProgressAndTaskItem = getTaskProgressAndNextTaskItem();
407+
if (taskProgressAndTaskItem.getTaskId() == -1)
406408
break;
407-
startTask(taskProgressAndTaskItem);
409+
claimedInitialTasks.add(taskProgressAndTaskItem);
408410
}
411+
412+
//Start initial tasks
413+
for (TaskProgress<I> claimedTask : claimedInitialTasks)
414+
startTask(claimedTask);
409415
}
410416

411417
/**

0 commit comments

Comments
 (0)