log refactor

Netflix · Dec 18, 2024 · 547a26d · 547a26d
1 parent 4fb2608
commit 547a26d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java b/...mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java
@@ -1943,18 +1943,18 @@ public void checkHeartBeats(Instant currentTime) {
                                 acceptedAt);
                         }
                     } else {
+                        // no heartbeat or heartbeat too old
                         if (!workerMeta.getLastHeartbeatAt().isPresent() || Duration.between(workerMeta.getLastHeartbeatAt().get(), currentTime).getSeconds()
                             > missedHeartBeatToleranceSecs) {
-                            // no heartbeat or heartbeat too old
                             this.numWorkerMissingHeartbeat.increment();
 
                             if (!workerMeta.getLastHeartbeatAt().isPresent()) {
-                                LOGGER.info("Job {}, Worker {} hasn't received heartbeat, threshold {} exceeded",
+                                LOGGER.warn("Job {}, Worker {} hasn't received heartbeat, threshold {} exceeded",
                                     this.jobMgr.getJobId(),
                                     workerMeta.getWorkerId(),
                                     missedHeartBeatToleranceSecs);
                             } else {
-                                LOGGER.info("Job {}, Worker {} Duration between last heartbeat and now {} "
+                                LOGGER.warn("Job {}, Worker {} Duration between last heartbeat and now {} "
                                         + "missed heart beat threshold {} exceeded",
                                     this.jobMgr.getJobId(),
                                     workerMeta.getWorkerId(),