Don't use WeaklyUp immediately, #23554

* see description in issue
2017-08-22 12:00:42 +02:00 · 2017-08-22 12:00:42 +02:00 · 6753c1e624
commit 6753c1e624
parent 1ba5b27158
2 changed files with 5 additions and 3 deletions
--- a/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
+++ b/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
@ -1005,10 +1005,10 @@ private[cluster] class ClusterCoreDaemon(publisher: ActorRef) extends Actor with
        leaderActionCounter = 0
        leaderActionsOnConvergence()
      } else {
-        if (cluster.settings.AllowWeaklyUpMembers)
+        leaderActionCounter += 1
+        if (cluster.settings.AllowWeaklyUpMembers && leaderActionCounter >= 3)
          moveJoiningToWeaklyUp()

-        leaderActionCounter += 1
        if (leaderActionCounter == firstNotice || leaderActionCounter % periodicNotice == 0)
          logInfo(
            "Leader can currently not perform its duties, reachability status: [{}], member status: [{}]",