From b3363710136ea14158f00566c12910d24dbe5b1f Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Wed, 1 Dec 2021 10:39:33 +0100 Subject: [PATCH] Retry ActorSelection resolve in LargeMessagesStreamSpec, #24143 (#30954) * failed with ActorNotFound in aeron-udp multi-node tests --- .../scala/akka/remote/artery/LargeMessagesStreamSpec.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala index 28973d065b..fd40c84e8a 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala @@ -149,5 +149,9 @@ class LargeMessagesStreamSpec } } - def awaitResolve(selection: ActorSelection): ActorRef = Await.result(selection.resolveOne(3.seconds), 3.seconds) + def awaitResolve(selection: ActorSelection): ActorRef = { + awaitAssert { + Await.result(selection.resolveOne(1.second), 1.seconds) + } + } }