diff --git a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ExternalShardAllocationSpec.scala b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ExternalShardAllocationSpec.scala index 89ee7a38ee..8502495c75 100644 --- a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ExternalShardAllocationSpec.scala +++ b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ExternalShardAllocationSpec.scala @@ -135,7 +135,7 @@ abstract class ExternalShardAllocationSpec } enterBarrier("allocated-to-new-node") runOn(forth) { - joinWithin(first) + joinWithin(first, max = 10.seconds) } enterBarrier("forth-node-joined") runOn(first, second, third) { diff --git a/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/singleton/ClusterSingletonManagerLeaseSpec.scala b/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/singleton/ClusterSingletonManagerLeaseSpec.scala index 4ee6fbb708..78d87fd130 100644 --- a/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/singleton/ClusterSingletonManagerLeaseSpec.scala +++ b/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/singleton/ClusterSingletonManagerLeaseSpec.scala @@ -94,24 +94,30 @@ class ClusterSingletonManagerLeaseSpec awaitClusterUp(controller, first) enterBarrier("initial-up") runOn(second) { - joinWithin(first) - awaitAssert({ - cluster.state.members.toList.map(_.status) shouldEqual List(Up, Up, Up) - }, 10.seconds) + within(10.seconds) { + joinWithin(first) + awaitAssert { + cluster.state.members.toList.map(_.status) shouldEqual List(Up, Up, Up) + } + } } enterBarrier("second-up") runOn(third) { - joinWithin(first) - awaitAssert({ - cluster.state.members.toList.map(_.status) shouldEqual List(Up, Up, Up, Up) - }, 10.seconds) + within(10.seconds) { + joinWithin(first) + awaitAssert { + cluster.state.members.toList.map(_.status) shouldEqual List(Up, Up, Up, Up) + } + } } enterBarrier("third-up") runOn(fourth) { - joinWithin(first) - awaitAssert({ - cluster.state.members.toList.map(_.status) shouldEqual List(Up, Up, Up, Up, Up) - }, 10.seconds) + within(10.seconds) { + joinWithin(first) + awaitAssert { + cluster.state.members.toList.map(_.status) shouldEqual List(Up, Up, Up, Up, Up) + } + } } enterBarrier("fourth-up") }