From 4763ca70b0dafa0b7da91a3541db2692cfd130aa Mon Sep 17 00:00:00 2001 From: Andy Zhang <87735571+Andyz26@users.noreply.github.com> Date: Thu, 14 Dec 2023 11:32:32 -0800 Subject: [PATCH] add log on coreMap update (#610) --- .../master/resourcecluster/ExecutorStateManagerImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java b/mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java index 434d1f1bd..c73b2498e 100644 --- a/mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java +++ b/mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java @@ -116,6 +116,7 @@ private boolean tryMarkAvailable(TaskExecutorID taskExecutorID, TaskExecutorStat log.debug("Marking executor {} as available for matching.", teHolder); double cpuCores = state.getRegistration().getMachineDefinition().getCpuCores(); if (!this.executorByCores.containsKey(cpuCores)) { + log.info("[executorByCores] adding {} from TE: {}", cpuCores, teHolder); this.executorByCores.putIfAbsent( cpuCores, new TreeSet<>(TaskExecutorHolder.generationFirstComparator));