This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new bc2d11cafe Release lease on shard stop (#2738)
bc2d11cafe is described below
commit bc2d11cafe490ac8e99630808490d26f7c2a531c
Author: Philippus Baalman <[email protected]>
AuthorDate: Mon Mar 16 13:32:42 2026 +0100
Release lease on shard stop (#2738)
---
.../src/main/scala/org/apache/pekko/cluster/sharding/Shard.scala | 1 +
1 file changed, 1 insertion(+)
diff --git
a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/Shard.scala
b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/Shard.scala
index 0eafe4ea8b..3792484f86 100644
---
a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/Shard.scala
+++
b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/Shard.scala
@@ -1192,6 +1192,7 @@ private[pekko] class Shard(
override def postStop(): Unit = {
passivateIntervalTask.foreach(_.cancel())
+ lease.foreach(_.release())
log.debug("{}: Shard [{}] shutting down", typeName, shardId)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
