Fix

Netflix · Oct 26, 2023 · dbf0ed9 · dbf0ed9
1 parent ea6ee67
commit dbf0ed9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java b/...ane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java
@@ -237,16 +237,19 @@ public Optional<Entry<TaskExecutorID, TaskExecutorState>> findFirst(
 
     @Override
     public void markJobAsStartedRequest(String jobId) {
+        log.info("[fdc-111] markJobAsStartedRequest {}", jobId);
         taskExecutorStateMap
                 .values()
                 .stream()
                 .filter(s -> s.getRegistration() != null && s.getWorkerId() != null && s.getWorkerId().getJobId().equals(jobId))
                 .forEach(s -> {
                     MachineDefinition m = s.getRegistration().getMachineDefinition();
                     if (unavailabilityByMachineDef.containsKey(m.getCpuCores())) {
+                        log.info("[fdc-111] markJobAsStartedRequest {} - totMissing: {}", jobId, unavailabilityByMachineDef.get(m.getCpuCores()) - 1);
                         unavailabilityByMachineDef.put(m.getCpuCores(), unavailabilityByMachineDef.get(m.getCpuCores()) - 1);
                     }
                 });
+        jobIds.remove(jobId);
     }
 
     @Override