[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-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

[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-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] [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-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-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-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-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-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-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] [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-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] [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] [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-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-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] [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] [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] [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] [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] [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=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-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] [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-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-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=17110788#comment-17110788 ] Canbin Zheng commented on FLINK-17565: -- [~fly_in_gis] Previously we discussed it in

[jira] [Commented] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110756#comment-17110756 ] Canbin Zheng commented on FLINK-17196: -- Thank you [~trohrmann]! > Improve the implementation of

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

[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15649: - Parent: FLINK-17709 Issue Type: Sub-task (was: New Feature) > Support mounting volumes

[jira] [Updated] (FLINK-15648) Support to configure limit for CPU requirement

[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15648: - Parent: FLINK-17709 Issue Type: Sub-task (was: New Feature) > Support to configure

[jira] [Updated] (FLINK-15648) Support to configure limit for CPU requirement

[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15648: - Parent: (was: FLINK-14460) Issue Type: New Feature (was: Sub-task) > Support to

[jira] [Commented] (FLINK-17709) Active Kubernetes integration phase 3 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-17709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107924#comment-17107924 ] Canbin Zheng commented on FLINK-17709: -- Sounds great! > Active Kubernetes integration phase 3 -

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

[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17480: - Summary: Support running PyFlink on Kubernetes (was: Support running PyFlink on native

[jira] [Updated] (FLINK-17480) Support running PyFlink on native Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17480: - Parent: FLINK-17709 Issue Type: Sub-task (was: New Feature) > Support running PyFlink

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

[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15656: - Parent: FLINK-17709 Issue Type: Sub-task (was: New Feature) > Support user-specified

[jira] [Updated] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17598: - Parent: FLINK-17709 Issue Type: Sub-task (was: New Feature) > Implement

[jira] [Updated] (FLINK-17707) Support configuring replica of Deployment in ZooKeeper based HA setups

[ https://issues.apache.org/jira/browse/FLINK-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17707: - Parent: FLINK-17709 Issue Type: Sub-task (was: New Feature) > Support configuring

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

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

[jira] [Created] (FLINK-17709) Active Kubernetes integration phase 3 - Advanced Features

Canbin Zheng created FLINK-17709: Summary: Active Kubernetes integration phase 3 - Advanced Features Key: FLINK-17709 URL: https://issues.apache.org/jira/browse/FLINK-17709 Project: Flink

[jira] [Updated] (FLINK-17709) Active Kubernetes integration phase 3 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-17709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17709: - Description: This is the umbrella issue to track all the advanced features for phase 3 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: - Fix Version/s: 1.11.0 > Bump fabric8 version from 4.5.2 to 4.9.1 >

[jira] [Created] (FLINK-17707) Support configuring replica of Deployment in ZooKeeper based HA setups

Canbin Zheng created FLINK-17707: Summary: Support configuring replica of Deployment in ZooKeeper based HA setups Key: FLINK-17707 URL: https://issues.apache.org/jira/browse/FLINK-17707 Project:

[jira] [Comment Edited] (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=17104007#comment-17104007 ] Canbin Zheng edited comment on FLINK-17565 at 5/14/20, 1:42 PM: Hi

[jira] [Commented] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107300#comment-17107300 ] Canbin Zheng commented on FLINK-17196: -- Yes [~fly_in_gis]. Hi, [~trohrmann], could you help assign

[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] [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] [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-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104284#comment-17104284 ] Canbin Zheng commented on FLINK-17598: -- > So do you mean to use StatefulSet to replace the

[jira] [Comment Edited] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104040#comment-17104040 ] Canbin Zheng edited comment on FLINK-17598 at 5/11/20, 3:48 AM:

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104040#comment-17104040 ] Canbin Zheng commented on FLINK-17598: -- [~fly_in_gis] Not exactly. The *StatefulSet* could ensure

[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=17104007#comment-17104007 ] Canbin Zheng commented on FLINK-17565: -- Hi [~tison]! At the moment this ticket first aims to solve

[jira] [Updated] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17598: - Description: At the moment we use Zookeeper as a distributed coordinator for implementing

[jira] [Created] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

Canbin Zheng created FLINK-17598: Summary: Implement FileSystemHAServices for native K8s setups Key: FLINK-17598 URL: https://issues.apache.org/jira/browse/FLINK-17598 Project: Flink Issue

[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] [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] [Commented] (FLINK-14146) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102517#comment-17102517 ] Canbin Zheng commented on FLINK-14146: -- +1, looking forward to faster progress of this feature. >

[jira] [Commented] (FLINK-14101) Introduce SqlServerDialect

[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102484#comment-17102484 ] Canbin Zheng commented on FLINK-14101: -- [~f.pompermaier] Go ahead! > Introduce SqlServerDialect >

[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-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 commented on FLINK-17566: -- Not exactly. Version 4.5.2 doesn't send one API request

[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] [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-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-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-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] [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] [Created] (FLINK-17549) Support running Stateful Functions on native Kubernetes setup

Canbin Zheng created FLINK-17549: Summary: Support running Stateful Functions on native Kubernetes setup Key: FLINK-17549 URL: https://issues.apache.org/jira/browse/FLINK-17549 Project: Flink

[jira] [Commented] (FLINK-17515) Move YARN staging functionality to a separate class

[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099658#comment-17099658 ] Canbin Zheng commented on FLINK-17515: -- I got it. Thanks for the explanation [~kkl0u]! > Move YARN

[jira] [Commented] (FLINK-14100) Introduce OracleDialect

[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099639#comment-17099639 ] Canbin Zheng commented on FLINK-14100: --  Not sure whether I have enough time for this subtask these

[jira] [Commented] (FLINK-17515) Move file uploading functionality to a separate class

[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099633#comment-17099633 ] Canbin Zheng commented on FLINK-17515: -- Not very sure whether the file uploading functionality is

[jira] [Commented] (FLINK-17509) Support OracleDialect

[ https://issues.apache.org/jira/browse/FLINK-17509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099604#comment-17099604 ] Canbin Zheng commented on FLINK-17509: -- Is it a duplicate of FLINK-14100 ? > Support OracleDialect

[jira] [Updated] (FLINK-17480) Support running PyFlink on native Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17480: - Description: This is the umbrella issue for running PyFlink on Kubernetes in native mode.

[jira] [Updated] (FLINK-17480) Support running PyFlink on native Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17480: - Summary: Support running PyFlink on native Kubernetes setup (was: Support PyFlink on native

[jira] [Created] (FLINK-17480) Support PyFlink on native Kubernetes setup

Canbin Zheng created FLINK-17480: Summary: Support PyFlink on native Kubernetes setup Key: FLINK-17480 URL: https://issues.apache.org/jira/browse/FLINK-17480 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

[ https://issues.apache.org/jira/browse/FLINK-17332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17332: - Priority: Minor (was: Major) > Fix restart policy not equals to Never for native task manager

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094076#comment-17094076 ] Canbin Zheng commented on FLINK-16478: -- In addition to the rest API support, could we also support

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094071#comment-17094071 ] Canbin Zheng commented on FLINK-16478: -- {quote}[~felixzheng] yes, that depends on how the logger

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092473#comment-17092473 ] Canbin Zheng commented on FLINK-16478: -- [~xiaodao] [~dixingx...@yeah.net] Would it be possible that

[jira] [Commented] (FLINK-17382) Flink should support dynamic log level setting

[ https://issues.apache.org/jira/browse/FLINK-17382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092438#comment-17092438 ] Canbin Zheng commented on FLINK-17382: -- Is it a duplicate of  FLINK-16478 ? > Flink should support

[jira] [Comment Edited] (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=17091491#comment-17091491 ] Canbin Zheng edited comment on FLINK-17032 at 4/24/20, 11:41 AM: -

[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=17091491#comment-17091491 ] Canbin Zheng commented on FLINK-17032: -- {quote}Another property that I would consider desirable is

[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: - Description: Currently, the naming rules are different among the Kubernetes resources we have

[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: - Description: Currently, the naming rules are different among the Kubernetes resources 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=17091413#comment-17091413 ] Canbin Zheng commented on FLINK-17100: -- {quote}do you mean in the title "Improvements for Native

[jira] [Updated] (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 updated FLINK-17100: - Summary: Improvements for Native Kubernetes Documentation (was: Document Native Kubernetes

[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=17091156#comment-17091156 ] Canbin Zheng commented on FLINK-17273: -- Thanks a lot for the input [~trohrmann] [~xintongsong]. I

[jira] [Created] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

Canbin Zheng created FLINK-17332: Summary: Fix restart policy not equals to Never for native task manager pods Key: FLINK-17332 URL: https://issues.apache.org/jira/browse/FLINK-17332 Project: Flink

[jira] [Updated] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

[ https://issues.apache.org/jira/browse/FLINK-17332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17332: - Description: Currently, we do not explicitly set the {{RestartPolicy}} for the task manager

[jira] [Comment Edited] (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=17089254#comment-17089254 ] Canbin Zheng edited comment on FLINK-17273 at 4/22/20, 3:25 AM: Thanks

[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=17089254#comment-17089254 ] Canbin Zheng commented on FLINK-17273: -- Thanks for your attention! [~xintongsong] [~fly_in_gis]

[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=17088495#comment-17088495 ] Canbin Zheng commented on FLINK-17176: -- [~fly_in_gis], you can take over this subtask if you are

[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=17088276#comment-17088276 ] Canbin Zheng commented on FLINK-17273: -- cc [~xintongsong] > Fix not calling

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

Canbin Zheng created FLINK-17273: Summary: Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure Key: FLINK-17273 URL:

  1   2   3   4   5   >