From 092178651202f7ebf8427a1ce52d2a108485036e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Mon, 13 Jul 2020 16:31:11 +0200 Subject: [PATCH] Durable pruning fail fix #29270 Failed once when the new cluster node had not joined the cluster yet, so start with waiting for that. --- .../scala/akka/cluster/ddata/DurablePruningSpec.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala index 730df3fd4e..5f8a3a86fa 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/DurablePruningSpec.scala @@ -169,6 +169,11 @@ class DurablePruningSpec extends MultiNodeSpec(DurablePruningSpec) with STMultiN val probe3 = TestProbe()(sys3) cluster3.join(node(first).address) + awaitAssert({ + cluster.state.members.exists(m => + m.uniqueAddress == cluster3.selfUniqueAddress && m.status == MemberStatus.Up) should ===(true) + }, 10.seconds) + within(10.seconds) { var values = Set.empty[Int] awaitAssert {