From 1d26fc97aba464ca85bf301ea40e8e0017762267 Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Fri, 21 Sep 2018 09:26:10 +0200 Subject: [PATCH] Add troubleshooting hint to logging --- .../main/scala/akka/cluster/sharding/ShardCoordinator.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala index 21bdaf9dd6..6c6f77e11c 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala @@ -1025,7 +1025,8 @@ class DDataShardCoordinator(typeName: String, settings: ClusterShardingSettings, case UpdateTimeout(CoordinatorStateKey, Some(`evt`)) ⇒ log.error( - "The ShardCoordinator was unable to update a distributed state within 'updating-state-timeout': {} millis (retrying), event={}", + "The ShardCoordinator was unable to update a distributed state within 'updating-state-timeout': {} millis (retrying). " + + "Perhaps the ShardRegion has not started on all active nodes yet? event={}", writeMajority.timeout.toMillis, evt) // repeat until UpdateSuccess sendCoordinatorStateUpdate(evt)