Akka从2.6.9升级到2.6.10时LeastShardAllocationStrategy触发NPE

问题复现场景 #

• 最小复现工程配置：采用集群模式下Artery远程传输、种子节点、脑裂仲裁的基础application.conf配置，实现了包含自定义实体ID提取、分片ID生成、自定义分片分配策略的Sharding示例代码
• 版本差异表现：Akka 2.6.9版本下应用可正常启动运行，分片分配、重平衡逻辑均按预期执行，日志输出符合要求；切换至Akka 2.6.10版本后，执行分片分配与重平衡操作时直接抛出java.lang.NullPointerException
• 堆栈定位：异常触发链路为自定义包装的ShardAllocationStrategy内部调用原生LeastShardAllocationStrategy的allocateShard分片分配、rebalance分片重平衡逻辑，空指针根源为AbstractLeastShardAllocationStrategy的clusterState方法返回空值

根本原因 #

Akka 2.6.10对AbstractLeastShardAllocationStrategy的实现逻辑做了非兼容性调整：移除了原先从构造函数隐式上下文中自动解析绑定Cluster实例的实现，内部依赖的clusterState字段仅在构造时显式传入合法Cluster实例的场景下才会完成初始化。该调整属于2.6小版本中的非预期兼容性破坏，并未在常规小版本升级的风险提示中重点标注。

• 2.6.9版本中，原生LeastShardAllocationStrategy支持通过隐式传入的ActorSystem自动获取并绑定Cluster实例，完成clusterState初始化；自定义包装策略此前依赖该隐式能力完成实例化，实例化原生策略时未显式传入Cluster参数
• 2.6.10版本移除隐式绑定逻辑后，自定义策略实例化原生分配策略时无合法Cluster入参，导致clusterState字段始终为null，一旦调用分片分配、重平衡相关逻辑就会触发空指针异常

适配解决方式 #

• 调整原生LeastShardAllocationStrategy的初始化逻辑：在自定义包装策略类内部实例化原生分配策略时，显式将当前运行环境下的Cluster实例作为构造参数传入，不再依赖隐式上下文自动解析获取
• 把控初始化时序：Cluster实例的获取需在ActorSystem完成集群节点启动、与种子节点完成连通之后再执行分配策略的实例化，避免传入未完成状态的Cluster对象引发其他运行时异常
• 全链路校验：确认所有调用原生分配策略的allocateShard、rebalance方法的逻辑，均基于已经完成clusterState初始化的策略实例发起，避免绕过初始化流程直接调用未初始化的实例方法

内容的提问来源于stack exchange，提问作者Divyanshu