From 99841d0ce496ced45f576923a84741d88aba86e0 Mon Sep 17 00:00:00 2001 From: Harshit Mittal Date: Mon, 29 Apr 2024 19:22:15 -0700 Subject: [PATCH] add requested/allocated batchsize in the log --- .../master/resourcecluster/ExecutorStateManagerImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 a98d57dab..179cb0f58 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 @@ -512,7 +512,8 @@ private Optional> findTaskExecutorsFor(Ta if (taskExecutors.isPresent() && taskExecutors.get().size() == allocationRequests.size()) { return taskExecutors; } else { - log.warn("Not enough available TEs found for scheduling constraints {}, request: {}", schedulingConstraints, request); + log.warn("Not enough available TEs (got: {}, desired: {}) found for scheduling constraints {}, request: {}", + taskExecutors.map(Map::size).orElse(0), allocationRequests.size(), schedulingConstraints, request); // If there are not enough workers with the given spec then add the request the pending ones if (!isJobIdAlreadyPending && request.getAllocationRequests().size() > 2) {