From 13145058315a12dd31b2cc38f4e8be99c9f52408 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Wed, 18 Mar 2026 15:28:50 +0100 Subject: [PATCH] tests: Disable JoinConfigCompatCheckerSpec and HandshakeRetrySpec on aeron, unstable --- .../cluster/JoinConfigCompatCheckerSpec.scala | 36 ++++++++++--------- .../remote/artery/HandshakeRetrySpec.scala | 3 +- 2 files changed, 22 insertions(+), 17 deletions(-) diff --git a/akka-cluster/src/test/scala/akka/cluster/JoinConfigCompatCheckerSpec.scala b/akka-cluster/src/test/scala/akka/cluster/JoinConfigCompatCheckerSpec.scala index d16f367dafa..aa024f03453 100644 --- a/akka-cluster/src/test/scala/akka/cluster/JoinConfigCompatCheckerSpec.scala +++ b/akka-cluster/src/test/scala/akka/cluster/JoinConfigCompatCheckerSpec.scala @@ -9,7 +9,7 @@ import scala.concurrent.duration._ import com.typesafe.config.{ Config, ConfigFactory } -import akka.testkit.{ AkkaSpec, LongRunningTest } +import akka.testkit.{ AkkaSpec, GHExcludeAeronTest, LongRunningTest } object JoinConfigCompatCheckerSpec { @@ -47,9 +47,13 @@ object JoinConfigCompatCheckerSpec { class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { import JoinConfigCompatCheckerSpec._ + // All tests are long-running and excluded from aeron transport CI runs + override def tags: Map[String, Set[String]] = + testNames.map(_ -> Set(LongRunningTest.name, GHExcludeAeronTest.name)).toMap + "A Joining Node" must { - "be allowed to join a cluster when its configuration is compatible" taggedAs LongRunningTest in { + "be allowed to join a cluster when its configuration is compatible" in { val clusterTestUtil = new ClusterTestUtil(system.name) // first node @@ -65,7 +69,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "NOT be allowed to join a cluster when its configuration is incompatible" taggedAs LongRunningTest in { + "NOT be allowed to join a cluster when its configuration is incompatible" in { // this config is NOT compatible with the cluster config val joinNodeConfig = ConfigFactory.parseString(""" @@ -102,7 +106,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "NOT be allowed to join a cluster when one of its required properties are not available on cluster side" taggedAs LongRunningTest in { + "NOT be allowed to join a cluster when one of its required properties are not available on cluster side" in { // this config is NOT compatible with the cluster config // because there is one missing required configuration property. @@ -143,7 +147,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "NOT be allowed to join a cluster when one of the cluster required properties are not available on the joining side" taggedAs LongRunningTest in { + "NOT be allowed to join a cluster when one of the cluster required properties are not available on the joining side" in { // this config is NOT compatible with the cluster config // because there is one missing required configuration property. @@ -180,7 +184,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "be allowed to join a cluster when one of its required properties are not available on cluster side but it's configured to NOT enforce it" taggedAs LongRunningTest in { + "be allowed to join a cluster when one of its required properties are not available on cluster side but it's configured to NOT enforce it" in { // this config is NOT compatible with the cluster config // because there is one missing required configuration property. @@ -218,7 +222,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "be allowed to join a cluster when its configuration is incompatible but it's configured to NOT enforce it" taggedAs LongRunningTest in { + "be allowed to join a cluster when its configuration is incompatible but it's configured to NOT enforce it" in { // this config is NOT compatible with the cluster config, // but node will ignore the the config check and join anyway val joinNodeConfig = @@ -253,7 +257,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } /** This test verifies the built-in JoinConfigCompatCheckerAkkaCluster */ - "NOT be allowed to join a cluster using a different value for akka.cluster.downing-provider-class" taggedAs LongRunningTest in { + "NOT be allowed to join a cluster using a different value for akka.cluster.downing-provider-class" in { val joinNodeConfig = ConfigFactory.parseString(""" @@ -292,7 +296,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { "A First Node" must { - "be allowed to re-join a cluster when its configuration is compatible" taggedAs LongRunningTest in { + "be allowed to re-join a cluster when its configuration is compatible" in { val clusterTestUtil = new ClusterTestUtil(system.name) // first node @@ -319,7 +323,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "NOT be allowed to re-join a cluster when its configuration is incompatible" taggedAs LongRunningTest in { + "NOT be allowed to re-join a cluster when its configuration is incompatible" in { // this config is NOT compatible with the cluster config val joinNodeConfig = ConfigFactory.parseString(""" @@ -362,7 +366,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "NOT be allowed to re-join a cluster when one of its required properties are not available on cluster side" taggedAs LongRunningTest in { + "NOT be allowed to re-join a cluster when one of its required properties are not available on cluster side" in { // this config is NOT compatible with the cluster config // because there is one missing required configuration property. @@ -410,7 +414,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "NOT be allowed to re-join a cluster when one of the cluster required properties are not available on the joining side" taggedAs LongRunningTest in { + "NOT be allowed to re-join a cluster when one of the cluster required properties are not available on the joining side" in { // this config is NOT compatible with the cluster config // because there is one missing required configuration property. @@ -454,7 +458,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "be allowed to re-join a cluster when one of its required properties are not available on cluster side but it's configured to NOT enforce it" taggedAs LongRunningTest in { + "be allowed to re-join a cluster when one of its required properties are not available on cluster side but it's configured to NOT enforce it" in { // this config is NOT compatible with the cluster config // because there is one missing required configuration property. @@ -502,7 +506,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } - "be allowed to re-join a cluster when its configuration is incompatible but it's configured to NOT enforce it" taggedAs LongRunningTest in { + "be allowed to re-join a cluster when its configuration is incompatible but it's configured to NOT enforce it" in { // this config is NOT compatible with the cluster config, // but node will ignore the the config check and join anyway val joinNodeConfig = @@ -549,7 +553,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } "A Cluster" must { - "NOT exchange sensitive config paths with joining node" taggedAs LongRunningTest in { + "NOT exchange sensitive config paths with joining node" in { // this config has sensitive properties that are not compatible with the cluster // the cluster will ignore them, because they are on the sensitive-config-path @@ -599,7 +603,7 @@ class JoinConfigCompatCheckerSpec extends AkkaSpec with ClusterTestKit { } } - "be allowed to disable a check" taggedAs LongRunningTest in { + "be allowed to disable a check" in { // this config has sensitive properties that are not compatible with the cluster // the cluster will ignore them, because they are on the sensitive-config-path diff --git a/akka-remote/src/test/scala/akka/remote/artery/HandshakeRetrySpec.scala b/akka-remote/src/test/scala/akka/remote/artery/HandshakeRetrySpec.scala index 021bd305890..e5e7d25233c 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/HandshakeRetrySpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/HandshakeRetrySpec.scala @@ -9,6 +9,7 @@ import scala.concurrent.duration._ import com.typesafe.config.ConfigFactory import akka.actor._ +import akka.testkit.GHExcludeAeronTest import akka.testkit.ImplicitSender import akka.testkit.TestActors @@ -26,7 +27,7 @@ class HandshakeRetrySpec extends ArteryMultiNodeSpec(HandshakeRetrySpec.commonCo "Artery handshake" must { - "be retried during handshake-timeout (no message loss)" in { + "be retried during handshake-timeout (no message loss)" taggedAs (GHExcludeAeronTest) in { def sel = system.actorSelection(s"akka://systemB@localhost:$portB/user/echo") sel ! "hello" expectNoMessage(1.second)