[jira] [Updated] (FLINK-15647) Support user-specified annotations for JM/TM pods

[ https://issues.apache.org/jira/browse/FLINK-15647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15647: - Summary: Support user-specified annotations for JM/TM pods (was: Support to set annotations

[jira] [Updated] (FLINK-16624) Support user-specified annotations for the rest Service

[ https://issues.apache.org/jira/browse/FLINK-16624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16624: - Summary: Support user-specified annotations for the rest Service (was: Support to customize

[jira] [Updated] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16715: - Description: In the YarnClusterDescriptor#{{startAppMaster()}} we are using some time the

[jira] [Updated] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16715: - Priority: Trivial (was: Minor) > Always use the configuration argument in

[jira] [Created] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

Canbin Zheng created FLINK-16715: Summary: Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained Key: FLINK-16715 URL:

[jira] [Commented] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S

[ https://issues.apache.org/jira/browse/FLINK-16717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064649#comment-17064649 ] Canbin Zheng commented on FLINK-16717: -- Is it a duplicate of FLINK-16602? > Use headless service

[jira] [Commented] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S

[ https://issues.apache.org/jira/browse/FLINK-16717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064689#comment-17064689 ] Canbin Zheng commented on FLINK-16717: -- Hi, [~wsfdl]! You are right. cc [~tison] > Use headless

[jira] [Comment Edited] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S

[ https://issues.apache.org/jira/browse/FLINK-16717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064689#comment-17064689 ] Canbin Zheng edited comment on FLINK-16717 at 3/23/20, 10:26 AM: - Hi,

[jira] [Commented] (FLINK-16733) Refactor YarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-16733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065274#comment-17065274 ] Canbin Zheng commented on FLINK-16733: -- Big +1 for the refactor. > Refactor YarnClusterDescriptor

[jira] [Updated] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16715: - Parent: FLINK-16733 Issue Type: Sub-task (was: Improvement) > Always use the

[jira] [Created] (FLINK-16737) Remove KubernetesUtils#getContentFromFile

Canbin Zheng created FLINK-16737: Summary: Remove KubernetesUtils#getContentFromFile Key: FLINK-16737 URL: https://issues.apache.org/jira/browse/FLINK-16737 Project: Flink Issue Type:

[jira] [Updated] (FLINK-16624) Support to customize annotations for the rest Service on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16624: - Description: There are some scenarios that people would like to customize annotations for the

[jira] [Created] (FLINK-16624) Support to customize annotations for the rest Service on Kubernetes

Canbin Zheng created FLINK-16624: Summary: Support to customize annotations for the rest Service on Kubernetes Key: FLINK-16624 URL: https://issues.apache.org/jira/browse/FLINK-16624 Project: Flink

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060607#comment-17060607 ] Canbin Zheng commented on FLINK-16602: -- Hi, Yang Wang! I know your concern. > About the rest port

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060662#comment-17060662 ] Canbin Zheng commented on FLINK-16602: -- Yes, you are right [~fly_in_gis]. Glad to reach a consensus

[jira] [Comment Edited] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060691#comment-17060691 ] Canbin Zheng edited comment on FLINK-15871 at 3/17/20, 7:46 AM:

[jira] [Commented] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060691#comment-17060691 ] Canbin Zheng commented on FLINK-15871: -- {color:#0e101a}Hi {color}[{color:#4a6ee0}Yang

[jira] [Commented] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060679#comment-17060679 ] Canbin Zheng commented on FLINK-15871: -- Hi, [~ouyangwuli]! > But I don't think deamonset is a good

[jira] [Commented] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060620#comment-17060620 ] Canbin Zheng commented on FLINK-15871: -- Hi, [~fly_in_gis]! The init container is a basic design

[jira] [Comment Edited] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060620#comment-17060620 ] Canbin Zheng edited comment on FLINK-15871 at 3/17/20, 4:19 AM:

[jira] [Comment Edited] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060620#comment-17060620 ] Canbin Zheng edited comment on FLINK-15871 at 3/17/20, 4:20 AM:

[jira] [Created] (FLINK-16625) Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtil

Canbin Zheng created FLINK-16625: Summary: Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtil Key: FLINK-16625 URL: https://issues.apache.org/jira/browse/FLINK-16625

[jira] [Commented] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060809#comment-17060809 ] Canbin Zheng commented on FLINK-15871: -- Hi, [~fly_in_gis]! I got your concern, I think this

[jira] [Commented] (FLINK-16508) Name the ports exposed by the main Container in Pod

[ https://issues.apache.org/jira/browse/FLINK-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102154#comment-17102154 ] Canbin Zheng commented on FLINK-16508: -- Hi [~tison] ! Sorry that I don't backport this PR to 1.10.1

[jira] [Updated] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.10.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17565: - Description: Currently, we are using a version of 4.5.2, it's better that we upgrade it to

[jira] [Created] (FLINK-17566) Fix potential K8s resources leak after JobManager finishes in Applicaion mode

Canbin Zheng created FLINK-17566: Summary: Fix potential K8s resources leak after JobManager finishes in Applicaion mode Key: FLINK-17566 URL: https://issues.apache.org/jira/browse/FLINK-17566

[jira] [Created] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.10.1

Canbin Zheng created FLINK-17565: Summary: Bump fabric8 version from 4.5.2 to 4.10.1 Key: FLINK-17565 URL: https://issues.apache.org/jira/browse/FLINK-17565 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17549) Support running Stateful Functions on native Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-17549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102149#comment-17102149 ] Canbin Zheng commented on FLINK-17549: -- HI [~igal]! Currently, it is a feature request ticket.

[jira] [Updated] (FLINK-16508) Name the ports exposed by the main Container in Pod

[ https://issues.apache.org/jira/browse/FLINK-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16508: - Fix Version/s: (was: 1.10.2) > Name the ports exposed by the main Container in Pod >

[jira] [Updated] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17565: - Description: Currently, we are using a version of 4.5.2, it's better that we upgrade it to

[jira] [Commented] (FLINK-17566) Fix potential K8s resources leak after JobManager finishes in Applicaion mode

[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103040#comment-17103040 ] Canbin Zheng commented on FLINK-17566: -- Right. According to the suggestion from the author of

[jira] [Updated] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17565: - Summary: Bump fabric8 version from 4.5.2 to 4.9.1 (was: Bump fabric8 version from 4.5.2 to

[jira] [Comment Edited] (FLINK-17566) Fix potential K8s resources leak after JobManager finishes in Applicaion mode

[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102365#comment-17102365 ] Canbin Zheng edited comment on FLINK-17566 at 5/8/20, 8:20 AM: --- Not

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111672#comment-17111672 ] Canbin Zheng commented on FLINK-17565: -- Updates: Since the fabric8 kubernetes-client community has

[jira] [Commented] (FLINK-17480) Support running PyFlink on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187667#comment-17187667 ] Canbin Zheng commented on FLINK-17480: -- Hi [~csq], [~fly_in_gis].  Feel free to take over this

[jira] [Commented] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185032#comment-17185032 ] Canbin Zheng commented on FLINK-17273: -- Hi [~xintongsong], I do not work on this issue, go ahead!

[jira] [Commented] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118563#comment-17118563 ] Canbin Zheng commented on FLINK-17230: -- > [~felixzheng] Could you open a PR to back this fix to

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.2

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116389#comment-17116389 ] Canbin Zheng commented on FLINK-17565: -- Thank you [~zjwang]. [~tison]  Should I make another PR

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.2

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116363#comment-17116363 ] Canbin Zheng commented on FLINK-17565: -- [~zjwang] 1.11 has supported application mode on

[jira] [Commented] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116369#comment-17116369 ] Canbin Zheng commented on FLINK-17230: -- [~zjwang] The scope of this problem is that the end-users

[jira] [Updated] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17230: - Parent: (was: FLINK-17196) Issue Type: Bug (was: Sub-task) > Fix incorrect

[jira] [Updated] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17230: - Priority: Blocker (was: Major) > Fix incorrect returned address of Endpoint for the ClusterIP

[jira] [Commented] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119193#comment-17119193 ] Canbin Zheng commented on FLINK-17230: -- > I think it makes sense to cover it in release-1.11. Could

[jira] [Commented] (FLINK-16855) Update K8s template for the standalone setup

[ https://issues.apache.org/jira/browse/FLINK-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151239#comment-17151239 ] Canbin Zheng commented on FLINK-16855: -- [~rmetzger] yes, this ticket mainly for updating the

[jira] [Updated] (FLINK-16855) Update K8s template for the standalone setup

[ https://issues.apache.org/jira/browse/FLINK-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16855: - Fix Version/s: (was: 1.11.0) 1.12.0 > Update K8s template for the

[jira] [Commented] (FLINK-17177) Handle ERROR event correctly in KubernetesResourceManager#onError

[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151250#comment-17151250 ] Canbin Zheng commented on FLINK-17177: -- [~rmetzger] I didn't look into this ticket in the past two

[jira] [Updated] (FLINK-17177) Handle ERROR event correctly in KubernetesResourceManager#onError

[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17177: - Fix Version/s: (was: 1.11.0) 1.12.0 > Handle ERROR event correctly in

[jira] [Commented] (FLINK-15649) Support mounting volumes

[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157314#comment-17157314 ] Canbin Zheng commented on FLINK-15649: -- >> users may just wish for mounting volume without

[jira] [Commented] (FLINK-15649) Support mounting volumes

[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157294#comment-17157294 ] Canbin Zheng commented on FLINK-15649: -- Hi, [~DaDaShen]. Previously I have finished this feature in

[jira] [Commented] (FLINK-16699) Support accessing secured services via K8s secrets

[ https://issues.apache.org/jira/browse/FLINK-16699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157297#comment-17157297 ] Canbin Zheng commented on FLINK-16699: -- Sorry for the late reply [~Leo Zhou]. Internally we have

[jira] [Commented] (FLINK-17100) Improvements for Native Kubernetes Documentation

[ https://issues.apache.org/jira/browse/FLINK-17100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151236#comment-17151236 ] Canbin Zheng commented on FLINK-17100: -- [~chesnay] Currently no progress. I would close this

[jira] [Closed] (FLINK-17100) Improvements for Native Kubernetes Documentation

[ https://issues.apache.org/jira/browse/FLINK-17100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-17100. Resolution: Invalid > Improvements for Native Kubernetes Documentation >

[jira] [Commented] (FLINK-17032) Naming convention unification for all the Kubernetes Resources

[ https://issues.apache.org/jira/browse/FLINK-17032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151246#comment-17151246 ] Canbin Zheng commented on FLINK-17032: -- > _Not sure I quite understand this; is it that the

[jira] [Updated] (FLINK-17032) Naming convention unification for all the Kubernetes Resources

[ https://issues.apache.org/jira/browse/FLINK-17032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17032: - Fix Version/s: (was: 1.11.0) 1.12.0 > Naming convention unification for

[jira] [Commented] (FLINK-17176) Slow down Pod re-creation in KubernetesResourceManager#PodCallbackHandler

[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151252#comment-17151252 ] Canbin Zheng commented on FLINK-17176: -- [~rmetzger] I close this ticket since FLINK-17127 could

[jira] [Commented] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151238#comment-17151238 ] Canbin Zheng commented on FLINK-17273: -- [~rmetzger] Sorry that I am busy in the past two months.

[jira] [Commented] (FLINK-17090) Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU

[ https://issues.apache.org/jira/browse/FLINK-17090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151233#comment-17151233 ] Canbin Zheng commented on FLINK-17090: -- [~chesnay] I think we could introduce such checks in 

[jira] [Updated] (FLINK-15843) Gracefully shutdown TaskManagers on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15843: - Fix Version/s: (was: 1.11.0) 1.12.0 > Gracefully shutdown TaskManagers

[jira] [Updated] (FLINK-17176) Slow down Pod re-creation in KubernetesResourceManager#PodCallbackHandler

[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17176: - Fix Version/s: (was: 1.11.0) 1.12.0 > Slow down Pod re-creation in

[jira] [Closed] (FLINK-17176) Slow down Pod re-creation in KubernetesResourceManager#PodCallbackHandler

[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-17176. Resolution: Incomplete > Slow down Pod re-creation in

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156427#comment-17156427 ] Canbin Zheng commented on FLINK-15656: -- Hi [~asardaes]! Thanks for your attention, I am working and

[jira] [Commented] (FLINK-15649) Support mounting volumes

[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163240#comment-17163240 ] Canbin Zheng commented on FLINK-15649: -- [~DaDaShen] Previously I don't think volume mounting is a

[jira] [Comment Edited] (FLINK-15649) Support mounting volumes

[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163400#comment-17163400 ] Canbin Zheng edited comment on FLINK-15649 at 7/23/20, 10:14 AM: - Hi

[jira] [Commented] (FLINK-15649) Support mounting volumes

[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163400#comment-17163400 ] Canbin Zheng commented on FLINK-15649: -- Hi [~azagrebin] ??I briefly looked into the PR. It looks

[jira] [Commented] (FLINK-15843) Gracefully shutdown TaskManagers on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163643#comment-17163643 ] Canbin Zheng commented on FLINK-15843: -- Hi [~trohrmann]! I will double check it then give feedback

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163641#comment-17163641 ] Canbin Zheng commented on FLINK-15656: -- Thanks, [~azagrebin]! > Support user-specified pod

<    1   2   3   4   5