Skip to content

Commit

Permalink
Fix NPE in coordinator when closing a half-initialized node controller (
Browse files Browse the repository at this point in the history
  • Loading branch information
merlimat committed Sep 20, 2024
1 parent da3a76c commit 15f9379
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion coordinator/impl/node_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -176,7 +176,9 @@ func (n *nodeController) healthCheckWithRetries() {

// To avoid the send assignments stream to miss the notification about the current
// node went down, we interrupt the current stream when the ping on the node fails
n.sendAssignmentsCancel()
if n.sendAssignmentsCancel != nil {
n.sendAssignmentsCancel()
}
})
}

Expand Down

0 comments on commit 15f9379

Please sign in to comment.