raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Fail fix in ClusterShardingPreparingForShutdownSpec (#30041)

Browse source
This commit is contained in:
Johan Andrén 2021-02-17 13:37:05 +01:00 • committed by GitHub
parent abbaffc303
commit 052f845e00
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/ClusterShardingPreparingForShutdownSpec.scala
View file

@ -1,5 +1,5 @@
/*
* Copyright (C) 2020 Lightbend Inc. <https://www.lightbend.com>
* Copyright (C) 2020-2021 Lightbend Inc. <https://www.lightbend.com>
*/
package akka.cluster.sharding.typed
@ -89,7 +89,6 @@ class ClusterShardingPreparingForShutdownSpec
runOn(second) {
cluster.manager ! PrepareForFullClusterShutdown
}
awaitAssert({
withClue("members: " + cluster.state.members) {
@ -118,9 +117,13 @@ class ClusterShardingPreparingForShutdownSpec
}
}, 5.seconds) // keep this lower than coordinated shutdown timeout
// trigger creation of a new shard should be fine even though one node left
runOn(first, third) {
shardRegion ! ShardingEnvelope("id3", Pinger.Ping(3, probe.ref))
probe.expectMessage(Pong(3))
awaitAssert({
shardRegion ! ShardingEnvelope("id3", Pinger.Ping(3, probe.ref))
probe.expectMessage(Pong(3))
}, 10.seconds)
}
enterBarrier("new-shards-verified")