check that the PVC provisioning request is for the current node

kubernetes-csi · Oct 4, 2019 · fa836f8 · fa836f8
1 parent 807ef93
commit fa836f8
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -380,6 +380,12 @@ func (p *csiProvisioner) ProvisionExt(options controller.ProvisionOptions) (*v1.
 		}
 	}
 
+	if options.SelectedNode.Name != os.Getenv("NODE_NAME") {
+		return nil, controller.ProvisioningNoChange, &controller.IgnoredError{
+			Reason: fmt.Sprintf("Selected node (%s) is not current node (%s)", options.SelectedNode.Name, os.Getenv("NODE_NAME")),
+		}
+	}
+
 	migratedVolume := false
 	if p.supportsMigrationFromInTreePluginName != "" {
 		// NOTE: we cannot depend on PVC.Annotations[volume.beta.kubernetes.io/storage-provisioner] to get