diff --git a/server/src/main/java/org/elasticsearch/action/datastreams/autosharding/DataStreamAutoShardingService.java b/server/src/main/java/org/elasticsearch/action/datastreams/autosharding/DataStreamAutoShardingService.java index d4b2a46b73e6d..72857c8249055 100644 --- a/server/src/main/java/org/elasticsearch/action/datastreams/autosharding/DataStreamAutoShardingService.java +++ b/server/src/main/java/org/elasticsearch/action/datastreams/autosharding/DataStreamAutoShardingService.java @@ -313,7 +313,7 @@ public String toString() { return Strings.format( "For data stream %s: %s based on [inc/dec cooldowns %s/%s, %d-%d threads, " + "write index %s has all-time/recent/peak loads %g/%g/%g, current shards %d, " - + "using %s value %g for increase gives %d shards%s]", + + "increase calculation gives %d shards using %s load %g for write index%s]", inputs.dataStream, result, inputs.increaseShardsCooldown, @@ -325,19 +325,19 @@ public String toString() { inputs.writeIndexRecentLoad, inputs.writeIndexPeakLoad, inputs.currentNumberOfWriteIndexShards, + increaseCalculation.optimalShardCountForIncrease, inputs.increaseShardsMetric, increaseCalculation.writeIndexLoadForIncrease, - increaseCalculation.optimalShardCountForIncrease, decreaseCalculation == null ? "" : Strings.format( - ", and using %s value %g for dec based on %s gives %d shards", + ", decrease calculation gives %d shards using %s load %g for %s", + decreaseCalculation.optimalShardCountForDecrease, inputs.decreaseShardsMetric, decreaseCalculation.maxLoadWithinCooldown.load, decreaseCalculation.maxLoadWithinCooldown.previousIndexWithMaxLoad != null ? decreaseCalculation.maxLoadWithinCooldown.previousIndexWithMaxLoad - : "write index", - decreaseCalculation.optimalShardCountForDecrease + : "write index" ) ); }