From 0f23ebdde1eb6475af0baf9f04d3e0d569469893 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Wed, 1 Mar 2023 21:18:18 -0600 Subject: [PATCH] fix state update timeout for remember-entities We were using the wrong state timeout value, which only gave us 2s to recover R-E data. We're now using the correct value. --- src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs b/src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs index bde0e262e19..f2855e9aadc 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs @@ -1117,7 +1117,7 @@ private void TryLoadRememberedEntities() Timers.StartSingleTimer( RememberEntityTimeoutKey, new RememberEntityTimeout(RememberEntitiesShardStore.GetEntities.Instance), - _settings.TuningParameters.WaitingForStateTimeout); + _settings.TuningParameters.UpdatingStateTimeout); Context.Become(AwaitingRememberedEntities); } else @@ -1254,7 +1254,7 @@ private void SendToRememberStore(IActorRef store, IImmutableSet storin Timers.StartSingleTimer( RememberEntityTimeoutKey, new RememberEntityTimeout(update), - _settings.TuningParameters.UpdatingStateTimeout); + _settings.TuningParameters.WaitingForStateTimeout); Context.Become(WaitingForRememberEntitiesStore(update, startTime)); }