Added check for pre-existing job in completed table.

This commit is contained in:
U-BASIS\dgrove 2017-09-27 09:49:17 -04:00
parent d31d3525ac
commit f9501ff770

View File

@ -343,6 +343,10 @@ public final class AutoIngestManager extends Observable implements PropertyChang
hostNamesToRunningJobs.remove(hostName);
if (event.shouldRetry() == false) {
synchronized (jobsLock) {
AutoIngestJob job = event.getJob();
if(completedJobs.contains(job)) {
completedJobs.remove(job);
}
completedJobs.add(event.getJob());
}
}