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

Add troubleshooting hint to logging

Browse source
This commit is contained in:
Arnout Engelen 2018-09-21 09:26:10 +02:00
parent 2a5f254f16
commit 1d26fc97ab
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1025,7 +1025,8 @@ class DDataShardCoordinator(typeName: String, settings: ClusterShardingSettings,
case UpdateTimeout(CoordinatorStateKey, Some(`evt`)) ⇒ case UpdateTimeout(CoordinatorStateKey, Some(`evt`)) ⇒
log.error( 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) writeMajority.timeout.toMillis, evt)
// repeat until UpdateSuccess // repeat until UpdateSuccess
sendCoordinatorStateUpdate(evt) sendCoordinatorStateUpdate(evt)