diff --git a/pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go b/pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go index 5cad0af1d4..6e11fc3de1 100644 --- a/pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go +++ b/pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go @@ -62,11 +62,14 @@ func (nsu *nodeStatusUpdater) UpdateNodeStatuses() error { for nodeName, attachedVolumes := range nodesToUpdate { nodeObj, exists, err := nsu.nodeInformer.GetStore().GetByKey(string(nodeName)) if nodeObj == nil || !exists || err != nil { - // If node does not exist, its status cannot be updated, log error and move on. - glog.V(5).Infof( + // If node does not exist, its status cannot be updated, log error and + // reset flag statusUpdateNeeded back to true to indicate this node status + // needs to be udpated again + glog.V(2).Infof( "Could not update node status. Failed to find node %q in NodeInformer cache. %v", nodeName, err) + nsu.actualStateOfWorld.SetNodeStatusUpdateNeeded(nodeName) continue } @@ -115,11 +118,12 @@ func (nsu *nodeStatusUpdater) UpdateNodeStatuses() error { nodeName, err) } - - glog.V(3).Infof( - "Updating status for node %q succeeded. patchBytes: %q", + glog.V(2).Infof( + "Updating status for node %q succeeded. patchBytes: %q VolumesAttached: %v", nodeName, - string(patchBytes)) + string(patchBytes), + node.Status.VolumesAttached) + } return nil }