Skip to content

Commit 99841d0

Browse files
committed
add requested/allocated batchsize in the log
1 parent 19082dc commit 99841d0

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -512,7 +512,8 @@ private Optional<Map<TaskExecutorID, TaskExecutorState>> findTaskExecutorsFor(Ta
512512
if (taskExecutors.isPresent() && taskExecutors.get().size() == allocationRequests.size()) {
513513
return taskExecutors;
514514
} else {
515-
log.warn("Not enough available TEs found for scheduling constraints {}, request: {}", schedulingConstraints, request);
515+
log.warn("Not enough available TEs (got: {}, desired: {}) found for scheduling constraints {}, request: {}",
516+
taskExecutors.map(Map::size).orElse(0), allocationRequests.size(), schedulingConstraints, request);
516517

517518
// If there are not enough workers with the given spec then add the request the pending ones
518519
if (!isJobIdAlreadyPending && request.getAllocationRequests().size() > 2) {

0 commit comments

Comments
 (0)