Fix job disoveryAPI HB (#520)

Netflix · Aug 11, 2023 · 82732d0 · 82732d0
1 parent 4d0fd66
commit 82732d0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...ain/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandlerAkkaImpl.java b/...ain/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandlerAkkaImpl.java
@@ -111,7 +111,7 @@ public CompletionStage<JobDiscoveryRouteProto.SchedInfoResponse> schedulingInfoS
                         Observable<JobSchedulingInfo> heartbeats =
                             Observable.interval(5, serverIdleConnectionTimeout.getSeconds() - 1, TimeUnit.SECONDS)
                                 .map(x -> {
-                                    if(!isJobCompleted.get()) {
+                                    if(isJobCompleted.get()) {
                                         return SCHED_INFO_HB_INSTANCE;
                                     } else {
                                         return completedJobSchedulingInfo;

diff --git a/...plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java b/...plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java
@@ -566,7 +566,7 @@ public Optional<JobWorker> processWorkerEvent(WorkerEvent event, MantisJobStore
             try {
                 worker.processEvent(event, jobStore);
             } catch (InvalidWorkerStateChangeException wex) {
-                LOGGER.warn("InvalidWorkerStateChangeException from {}: {}", wex);
+                LOGGER.warn("InvalidWorkerStateChangeException from: ", wex);
             }
 
             return of(worker);