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

Quieter logging for ShardCoordinator initialization (#30488)

Browse source 
* Log the first retry on 'info', then 'warning', and finally 'error'
This commit is contained in:
Arnout Engelen 2021-08-18 10:05:24 +02:00 • committed by GitHub
parent 6b71804de3
commit 51924f5026
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1432,6 +1432,7 @@ private[akka] class DDataShardCoordinator(
private var terminating = false private var terminating = false
private var getShardHomeRequests: Set[(ActorRef, GetShardHome)] = Set.empty private var getShardHomeRequests: Set[(ActorRef, GetShardHome)] = Set.empty
private var initialStateRetries = 0
private val rememberEntitiesStore = private val rememberEntitiesStore =
rememberEntitiesStoreProvider.map { provider => rememberEntitiesStoreProvider.map { provider =>
@ -1468,10 +1469,16 @@ private[akka] class DDataShardCoordinator(
onInitialState(existingState, rememberedShards) onInitialState(existingState, rememberedShards)
case GetFailure(CoordinatorStateKey, _) => case GetFailure(CoordinatorStateKey, _) =>
log.error( initialStateRetries += 1
"{}: The ShardCoordinator was unable to get an initial state within 'waiting-for-state-timeout': {} millis (retrying). Has ClusterSharding been started on all nodes?", val template =
typeName, "{}: The ShardCoordinator was unable to get an initial state within 'waiting-for-state-timeout': {} millis (retrying). Has ClusterSharding been started on all nodes?"
stateReadConsistency.timeout.toMillis) if (initialStateRetries == 1)
log.info(template, typeName, stateReadConsistency.timeout.toMillis)
else if (initialStateRetries < 5)
log.warning(template, typeName, stateReadConsistency.timeout.toMillis)
else
log.error(template, typeName, stateReadConsistency.timeout.toMillis)
// repeat until GetSuccess // repeat until GetSuccess
getCoordinatorState() getCoordinatorState()