diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/QuickRestartSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/QuickRestartSpec.scala index bdd7143a47..3e1da843f2 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/QuickRestartSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/QuickRestartSpec.scala @@ -24,6 +24,7 @@ object QuickRestartMultiJvmSpec extends MultiNodeConfig { commonConfig(debugConfig(on = false). withFallback(ConfigFactory.parseString(""" akka.cluster.auto-down-unreachable-after = off + akka.cluster.allow-weakly-up-members = off """)). withFallback(MultiNodeClusterSpec.clusterConfig)) diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartFirstSeedNodeSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartFirstSeedNodeSpec.scala index 96286a8d2f..706a75abf1 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartFirstSeedNodeSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartFirstSeedNodeSpec.scala @@ -30,6 +30,7 @@ object RestartFirstSeedNodeMultiJvmSpec extends MultiNodeConfig { withFallback(ConfigFactory.parseString(""" akka.cluster.auto-down-unreachable-after = off akka.cluster.retry-unsuccessful-join-after = 3s + akka.cluster.allow-weakly-up-members = off """)). withFallback(MultiNodeClusterSpec.clusterConfig)) } diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode2Spec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode2Spec.scala index b171058c02..68c5a1697c 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode2Spec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode2Spec.scala @@ -28,9 +28,10 @@ object RestartNode2SpecMultiJvmSpec extends MultiNodeConfig { withFallback(ConfigFactory.parseString(""" akka.cluster.auto-down-unreachable-after = 2s akka.cluster.retry-unsuccessful-join-after = 3s + akka.cluster.allow-weakly-up-members = off akka.remote.retry-gate-closed-for = 45s akka.remote.log-remote-lifecycle-events = INFO - """)). + """)). withFallback(MultiNodeClusterSpec.clusterConfig)) } diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode3Spec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode3Spec.scala index e1eb6e1b73..230b8695fe 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode3Spec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNode3Spec.scala @@ -25,7 +25,10 @@ object RestartNode3MultiJvmSpec extends MultiNodeConfig { val third = role("third") commonConfig(debugConfig(on = false). - withFallback(ConfigFactory.parseString("akka.cluster.auto-down-unreachable-after = off")). + withFallback(ConfigFactory.parseString(""" + akka.cluster.auto-down-unreachable-after = off + akka.cluster.allow-weakly-up-members = off + """)). withFallback(MultiNodeClusterSpec.clusterConfig)) testTransport(on = true) diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNodeSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNodeSpec.scala index 0fe5927e01..614b0ec549 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNodeSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/RestartNodeSpec.scala @@ -31,6 +31,7 @@ object RestartNodeMultiJvmSpec extends MultiNodeConfig { commonConfig(debugConfig(on = false). withFallback(ConfigFactory.parseString(""" akka.cluster.auto-down-unreachable-after = 5s + akka.cluster.allow-weakly-up-members = off #akka.remote.use-passive-connections = off """)). withFallback(MultiNodeClusterSpec.clusterConfig))