Fix IngestTaskScheduler task cancellation

This commit is contained in:
Richard Cordovano 2015-03-07 21:16:58 -05:00
parent 22b55802f8
commit 60bafc0c6d

View File

@ -251,7 +251,6 @@ final class IngestTasksScheduler {
this.removeTasksForJob(this.directoryTasks, jobId);
this.removeTasksForJob(this.pendingFileTasks, jobId);
this.removeTasksForJob(this.pendingDataSourceTasks, jobId);
this.removeTasksForJob(this.tasksInProgress, jobId);
this.shuffleFileTaskQueues();
}
@ -465,6 +464,7 @@ final class IngestTasksScheduler {
while (iterator.hasNext()) {
IngestTask task = iterator.next();
if (task.getIngestJob().getId() == jobId) {
this.tasksInProgress.remove(task);
iterator.remove();
}
}