diff --git a/cmd/node-termination-handler.go b/cmd/node-termination-handler.go index 76f7fe49..a35e0f48 100644 --- a/cmd/node-termination-handler.go +++ b/cmd/node-termination-handler.go @@ -401,7 +401,7 @@ func cordonNode(node node.Node, nodeName string, drainEvent *monitor.Interruptio } func cordonAndDrainNode(node node.Node, nodeName string, drainEvent *monitor.InterruptionEvent, metrics observability.Metrics, recorder observability.K8sEventRecorder, sqsTerminationDraining bool) error { - err := node.CordonAndDrain(nodeName, drainEvent.Description) + err := node.CordonAndDrain(nodeName, drainEvent.Description, recorder.EventRecorder) if err != nil { if errors.IsNotFound(err) { log.Err(err).Msgf("node '%s' not found in the cluster", nodeName)