diff --git a/pkg/volume/util/operationexecutor/node_expander.go b/pkg/volume/util/operationexecutor/node_expander.go index a10f0af030d..a1beedec65e 100644 --- a/pkg/volume/util/operationexecutor/node_expander.go +++ b/pkg/volume/util/operationexecutor/node_expander.go @@ -18,6 +18,7 @@ package operationexecutor import ( "fmt" + v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/resource" clientset "k8s.io/client-go/kubernetes" @@ -100,6 +101,7 @@ func (ne *NodeExpander) expandOnPlugin() (bool, error, testResponseData) { } var err error + nodeName := ne.vmt.Pod.Spec.NodeName if !ne.pvcAlreadyUpdated { ne.pvc, err = util.MarkNodeExpansionInProgress(ne.pvc, ne.kubeClient) @@ -130,7 +132,7 @@ func (ne *NodeExpander) expandOnPlugin() (bool, error, testResponseData) { } return false, resizeErr, testResponseData{assumeResizeFinished: true, resizeCalledOnPlugin: true} } - simpleMsg, detailedMsg := ne.vmt.GenerateMsg("MountVolume.NodeExpandVolume succeeded", "") + simpleMsg, detailedMsg := ne.vmt.GenerateMsg("MountVolume.NodeExpandVolume succeeded", nodeName) ne.recorder.Eventf(ne.vmt.Pod, v1.EventTypeNormal, kevents.FileSystemResizeSuccess, simpleMsg) ne.recorder.Eventf(ne.pvc, v1.EventTypeNormal, kevents.FileSystemResizeSuccess, simpleMsg) klog.InfoS(detailedMsg, "pod", klog.KObj(ne.vmt.Pod)) diff --git a/pkg/volume/util/operationexecutor/operation_generator.go b/pkg/volume/util/operationexecutor/operation_generator.go index 8d4815e5a36..898acde5e5c 100644 --- a/pkg/volume/util/operationexecutor/operation_generator.go +++ b/pkg/volume/util/operationexecutor/operation_generator.go @@ -2155,6 +2155,8 @@ func (og *operationGenerator) legacyCallNodeExpandOnPlugin(resizeOp nodeResizeOp pvcStatusCap := pvc.Status.Capacity[v1.ResourceStorage] + nodeName := volumeToMount.Pod.Spec.NodeName + var err error // File system resize was requested, proceed @@ -2175,7 +2177,7 @@ func (og *operationGenerator) legacyCallNodeExpandOnPlugin(resizeOp nodeResizeOp return false, resizeErr } - simpleMsg, detailedMsg := volumeToMount.GenerateMsg("MountVolume.NodeExpandVolume succeeded", "") + simpleMsg, detailedMsg := volumeToMount.GenerateMsg("MountVolume.NodeExpandVolume succeeded", nodeName) og.recorder.Eventf(volumeToMount.Pod, v1.EventTypeNormal, kevents.FileSystemResizeSuccess, simpleMsg) og.recorder.Eventf(pvc, v1.EventTypeNormal, kevents.FileSystemResizeSuccess, simpleMsg) klog.InfoS(detailedMsg, "pod", klog.KObj(volumeToMount.Pod))