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

Merge pull request #25659 from akka/shardingErrorMessage

Browse source 
Add troubleshooting hint to logging
This commit is contained in:
Patrik Nordwall 2018-10-18 15:07:12 +02:00 • committed by GitHub
commit 751a67ef42
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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`)) ⇒
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)