You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by jn...@apache.org on 2026/03/28 06:37:18 UTC
(storm) 01/01: Fix NPE in mkAssignments when assignment is deleted during scheduling
This is an automated email from the ASF dual-hosted git repository.
jnioche pushed a commit to branch fix/nimbus-mkassignments-npe
in repository https://gitbox.apache.org/repos/asf/storm.git
commit 28d400a9f9d7e19a8e0a08de807f1adf54192c79
Author: Julien Nioche <ju...@digitalpebble.com>
AuthorDate: Sat Mar 28 06:35:56 2026 +0000
Fix NPE in mkAssignments when assignment is deleted during scheduling
Co-Authored-By: Claude Opus 4.6 <no...@anthropic.com>
---
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
index 18c5e5bdf..f6f31db65 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
@@ -2515,7 +2515,7 @@ public class Nimbus implements Iface, Shutdownable, DaemonCommon {
// will be treated as free slot in the scheduler code.
if (!id.equals(scratchTopoId)) {
Assignment currentAssignment = state.assignmentInfo(id, null);
- if (!currentAssignment.is_set_owner()) {
+ if (currentAssignment != null && !currentAssignment.is_set_owner()) {
TopologyDetails td = tds.get(id);
if (td != null) {
currentAssignment.set_owner(td.getTopologySubmitter());