This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch 1.5.x
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/1.5.x by this push:
new ab463e11bb Release lease on shard stop (#2740)
ab463e11bb is described below
commit ab463e11bb8be62b904124d6afcbfa2fc8bc9ff0
Author: Philippus Baalman <[email protected]>
AuthorDate: Tue Mar 17 00:59:50 2026 +0100
Release lease on shard stop (#2740)
---
.../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 ce81a8b588..36d35f3a54 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]
