raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Log non-completed rebalance at warning level (#28335)

Browse source
This commit is contained in:
Patrik Nordwall 2019-12-11 15:42:36 +01:00 • committed by Johan Andrén
parent 17533f077c
commit 5a69d7ad1c
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala
View file

@ -28,6 +28,7 @@ import akka.cluster.ddata.ReplicatedData
import akka.cluster.ddata.SelfUniqueAddress import akka.cluster.ddata.SelfUniqueAddress
import akka.event.BusLogging import akka.event.BusLogging
import akka.event.Logging import akka.event.Logging
import akka.util.PrettyDuration._
import akka.util.Timeout import akka.util.Timeout
import com.github.ghik.silencer.silent import com.github.ghik.silencer.silent
@ -649,7 +650,10 @@ abstract class ShardCoordinator(
continueRebalance(shards) continueRebalance(shards)
case RebalanceDone(shard, ok) => case RebalanceDone(shard, ok) =>
log.debug("Rebalance shard [{}] done [{}]", shard, ok) if (ok)
log.debug("Rebalance shard [{}] completed successfully.", shard)
else
log.warning("Rebalance shard [{}] didn't complete within [{}].", shard, handOffTimeout.pretty)
// The shard could have been removed by ShardRegionTerminated // The shard could have been removed by ShardRegionTerminated
if (state.shards.contains(shard)) { if (state.shards.contains(shard)) {
if (ok) { if (ok) {