hayden zhou created FLINK-20797: ----------------------------------- Summary: can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir Key: FLINK-20797 URL: https://issues.apache.org/jira/browse/FLINK-20797 Project: Flink Issue Type: New Feature Components: Client / Job Submission Environment: FLINK 1.12.0
Reporter: hayden zhou I want to deploy Flink on k8s with HA mode, and I don't want to deploy the HDFS cluster, and I have an NFS so that I am created a PV that use NFS as the backend storage, and I created a PVC for deployment mount. this is my FLINK configMap ``` kubernetes.cluster-id: mta-flink high-availability: org.apache.flink.kubernetes.highavailability. KubernetesHaServicesFactory high-availability.storageDir: file:///opt/flink/nfs/ha ``` and this is my jobmanager yaml file: ``` volumeMounts: - name: flink-config-volume mountPath: /opt/flink/conf - name: flink-nfs mountPath: /opt/flink/nfs securityContext: runAsUser: 9999 # refers to user _flink_ from official flink image, change if necessary #fsGroup: 9999 volumes: - name: flink-config-volume configMap: name: mta-flink-config items: - key: flink-conf.yaml path: flink-conf.yaml - key: log4j-console.properties path: log4j-console.properties - name: flink-nfs persistentVolumeClaim: claimName: mta-flink-nfs-pvc ``` It can be deployed successfully, but if I browser the jobmanager:8081 website, I get the result below: ``` {"errors": ["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} ``` is the PVC can be used as `high-availability.storageDir`? if it's can be used, how can I fix this error? -- This message was sent by Atlassian Jira (v8.3.4#803005)