Fixing typo and adding env var to deployment

kubernetes-sigs · Jun 15, 2022 · ad59768 · ad59768
1 parent 508e547
commit ad59768
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 1 deletion.
diff --git a/charts/aws-efs-csi-driver/templates/controller-deployment.yaml b/charts/aws-efs-csi-driver/templates/controller-deployment.yaml
@@ -61,6 +61,10 @@ spec:
             - name: AWS_STS_REGIONAL_ENDPOINTS
               value: regional
             {{- end }}
+            - name: CSI_NODE_NAME
+              valueFrom:
+                fieldRef:
+                  fieldPath: spec.nodeName
           volumeMounts:
             - name: socket-dir
               mountPath: /var/lib/csi/sockets/pluginproxy/

diff --git a/deploy/kubernetes/base/controller-deployment.yaml b/deploy/kubernetes/base/controller-deployment.yaml
@@ -40,6 +40,10 @@ spec:
           env:
             - name: CSI_ENDPOINT
               value: unix:///var/lib/csi/sockets/pluginproxy/csi.sock
+            - name: CSI_NODE_NAME
+              valueFrom:
+                fieldRef:
+                  fieldPath: spec.nodeName
           volumeMounts:
             - name: socket-dir
               mountPath: /var/lib/csi/sockets/pluginproxy/

diff --git a/pkg/cloud/k8s_metadata.go b/pkg/cloud/k8s_metadata.go
@@ -31,7 +31,7 @@ type kubernetesApiMetadataProvider struct {
 func (k kubernetesApiMetadataProvider) getMetadata() (MetadataService, error) {
 	nodeName := os.Getenv("CSI_NODE_NAME")
 	if nodeName == "" {
-		return nil, fmt.Errorf("CST_NODE_NAME env var not set")
+		return nil, fmt.Errorf("CSI_NODE_NAME env var not set")
 	}
 
 	node, err := k.api.CoreV1().Nodes().Get(context.TODO(), nodeName, metav1.GetOptions{})