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:17 UTC
(storm) branch fix/nimbus-mkassignments-npe created (now 28d400a9f)
This is an automated email from the ASF dual-hosted git repository.
jnioche pushed a change to branch fix/nimbus-mkassignments-npe
in repository https://gitbox.apache.org/repos/asf/storm.git
at 28d400a9f Fix NPE in mkAssignments when assignment is deleted during scheduling
This branch includes the following new commits:
new 28d400a9f Fix NPE in mkAssignments when assignment is deleted during scheduling
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(storm) 01/01: Fix NPE in mkAssignments when assignment is deleted during scheduling
Posted by jn...@apache.org.
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());