[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408503#comment-17408503 ]
Yang Wang commented on FLINK-22262: ----------------------------------- [~rmetzger] Thanks for reviving this discussion and sharing your use case. As a user, I think it is reasonable to have such a config option to set owner reference of HA related ConfigMaps to the JobManager deployment. The only major concern I still have is about the residual HA storage. Even though the HA related ConfigMaps could be deleted automatically, the HA storage(on the HDFS, S3, etc.) will be left behind. > Flink on Kubernetes ConfigMaps are created without OwnerReference > ----------------------------------------------------------------- > > Key: FLINK-22262 > URL: https://issues.apache.org/jira/browse/FLINK-22262 > Project: Flink > Issue Type: Bug > Components: Deployment / Kubernetes > Affects Versions: 1.13.0 > Reporter: Andrea Peruffo > Priority: Minor > Labels: auto-deprioritized-major > Attachments: jm.log > > > According to the documentation: > [https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/#manual-resource-cleanup] > The ConfigMaps created along with the Flink deployment is supposed to have an > OwnerReference pointing to the Deployment itself, unfortunately, this doesn't > happen and causes all sorts of issues when the classpath and the jars of the > job are updated. > i.e.: > Without manually removing the ConfigMap of the Job I cannot update the Jars > of the Job. > Can you please give guidance if there are additional caveats on manually > removing the ConfigMap? Any other workaround that can be used? > Thanks in advance. > Example ConfigMap: > {{apiVersion: v1}} > {{data:}} > {{ address: akka.tcp://flink@10.0.2.13:6123/user/rpc/jobmanager_2}} > {{ checkpointID-0000000000000000049: > rO0ABXNyADtvcmcuYXBhY2hlLmZsaW5rLnJ1bnRpbWUuc3RhdGUuUmV0cmlldmFibGVTdHJlYW1TdGF0ZUhhbmRsZQABHhjxVZcrAgABTAAYd3JhcHBlZFN0cmVhbVN0YXRlSGFuZGxldAAyTG9yZy9hcGFjaGUvZmxpbmsvcnVudGltZS9zdGF0ZS9TdHJlYW1TdGF0ZUhhbmRsZTt4cHNyADlvcmcuYXBhY2hlLmZsaW5rLnJ1bnRpbWUuc3RhdGUuZmlsZXN5c3RlbS5GaWxlU3RhdGVIYW5kbGUE3HXYYr0bswIAAkoACXN0YXRlU2l6ZUwACGZpbGVQYXRodAAfTG9yZy9hcGFjaGUvZmxpbmsvY29yZS9mcy9QYXRoO3hwAAAAAAABOEtzcgAdb3JnLmFwYWNoZS5mbGluay5jb3JlLmZzLlBhdGgAAAAAAAAAAQIAAUwAA3VyaXQADkxqYXZhL25ldC9VUkk7eHBzcgAMamF2YS5uZXQuVVJJrAF4LkOeSasDAAFMAAZzdHJpbmd0ABJMamF2YS9sYW5nL1N0cmluZzt4cHQAUC9tbnQvZmxpbmsvc3RvcmFnZS9rc2hhL3RheGktcmlkZS1mYXJlLXByb2Nlc3Nvci9jb21wbGV0ZWRDaGVja3BvaW50MDQ0YTc2OWRkNDgxeA==}} > {{ counter: "50"}} > {{ sessionId: 0c2b69ee-6b41-48d3-b7fd-1bf2eda94f0f}} > {{kind: ConfigMap}} > {{metadata:}} > {{ annotations:}} > {{ control-plane.alpha.kubernetes.io/leader: > '\{"holderIdentity":"0f25a2cc-e212-46b0-8ba9-faac0732a316","leaseDuration":15.000000000,"acquireTime":"2021-04-13T14:30:51.439000Z","renewTime":"2021-04-13T14:39:32.011000Z","leaderTransitions":105}'}} > {{ creationTimestamp: "2021-04-13T14:30:51Z"}} > {{ labels:}} > {{ app: taxi-ride-fare-processor}} > {{ configmap-type: high-availability}} > {{ type: flink-native-kubernetes}} > {{ name: > taxi-ride-fare-processor-00000000000000000000000000000000-jobmanager-leader}} > {{ namespace: taxi-ride-fare}} > {{ resourceVersion: "64100"}} > {{ selfLink: > /api/v1/namespaces/taxi-ride-fare/configmaps/taxi-ride-fare-processor-00000000000000000000000000000000-jobmanager-leader}} > {{ uid: 9f912495-382a-45de-a789-fd5ad2a2459d}} -- This message was sent by Atlassian Jira (v8.3.4#803005)