diff --git a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/MultiDcClusterShardingSpec.scala b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/MultiDcClusterShardingSpec.scala index 7a45b08500..65d8c30282 100644 --- a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/MultiDcClusterShardingSpec.scala +++ b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/MultiDcClusterShardingSpec.scala @@ -55,7 +55,9 @@ object MultiDcClusterShardingSpecConfig extends MultiNodeConfig { val fourth = role("fourth") commonConfig(ConfigFactory.parseString(s""" - akka.loglevel = INFO + # DEBUG because of failing test, issue #23582 + akka.loglevel = DEBUG + akka.cluster.debug.verbose-heartbeat-logging = on akka.actor.provider = "cluster" akka.remote.log-remote-lifecycle-events = off akka.cluster.auto-down-unreachable-after = 0s diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala index 036d997209..c02d0f0aa3 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala @@ -20,7 +20,10 @@ object MultiDcSplitBrainMultiJvmSpec extends MultiNodeConfig { commonConfig(ConfigFactory.parseString( """ - akka.loglevel = INFO + akka.loglevel = DEBUG + akka.cluster.debug.verbose-heartbeat-logging = on + akka.remote.netty.tcp.connection-timeout = 5 s # speedup in case of connection issue + akka.remote.retry-gate-closed-for = 1 s akka.cluster.multi-data-center { failure-detector { acceptable-heartbeat-pause = 4s @@ -99,7 +102,7 @@ abstract class MultiDcSplitBrainSpec val memberNodes = (dc1 ++ dc2).filterNot(notMembers) val probe = TestProbe() runOn(memberNodes: _*) { - cluster.subscribe(probe.ref, classOf[DataCenterReachabilityEvent]) + cluster.subscribe(probe.ref, classOf[ReachableDataCenter]) probe.expectMsgType[CurrentClusterState] } enterBarrier(s"unsplit-$barrierCounter") @@ -115,7 +118,7 @@ abstract class MultiDcSplitBrainSpec barrierCounter += 1 runOn(memberNodes: _*) { - probe.expectMsgType[ReachableDataCenter](15.seconds) + probe.expectMsgType[ReachableDataCenter](25.seconds) cluster.unsubscribe(probe.ref) awaitAssert { cluster.state.unreachableDataCenters should ===(Set.empty)