From 10c1dd89f03aa2a468f65b29b94f17e2a1d6dccc Mon Sep 17 00:00:00 2001 From: hmitnflx <100323213+hmitnflx@users.noreply.github.com> Date: Thu, 11 Jul 2024 11:29:04 -0700 Subject: [PATCH] fix log message when scaleDownThreshold is met (#690) --- .../java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java b/mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java index ee1555e45..c14d54625 100644 --- a/mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java +++ b/mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java @@ -490,7 +490,7 @@ public void onNext(Event event) { logger.debug("scale up NOOP: desiredWorkers same as current workers"); } } else if (stats.getLowThreshTriggered()) { - logger.info("Attempting to scale down stage {} of job {} by {} workers, because {} exceeded scaleUpThreshold of {} {} times", + logger.info("Attempting to scale down stage {} of job {} by {} workers, because {} is below scaleDownThreshold of {} {} times", stage, jobId, scalingPolicy.getDecrement(), event.getType(), strategy.getScaleDownBelowPct(), stats.getCurrentLowCount()); final int numCurrentWorkers = event.getNumWorkers();