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

2020-04-20 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087712#comment-17087712 ] Canbin Zheng commented on FLINK-15648: -- Thanks a lot for commenting on your concern

[jira] [Commented] (FLINK-15795) KubernetesClusterDescriptor seems to report unreachable JobManager interface URL

2020-04-20 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087589#comment-17087589 ] Canbin Zheng commented on FLINK-15795: -- Thanks [~trohrmann]. This issue will be res

[jira] [Commented] (FLINK-15331) Create a table from a changelog

2020-04-20 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087513#comment-17087513 ] Canbin Zheng commented on FLINK-15331: -- big +1 for this feature. > Create a table

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

2020-04-19 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087330#comment-17087330 ] Canbin Zheng commented on FLINK-17176: -- Previously these two tickets respect differ

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

2020-04-19 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087307#comment-17087307 ] Canbin Zheng commented on FLINK-17196: -- [~fly_in_gis], currently we don't clean up

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

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086732#comment-17086732 ] Canbin Zheng commented on FLINK-17196: -- Thanks, [~fly_in_gis]! They are already in

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

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17177: - Description: Currently, once we receive an *ERROR* event that is sent from the K8s API server vi

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

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086442#comment-17086442 ] Canbin Zheng commented on FLINK-17177: -- {quote}Since i find the fabric8 kubernetes

[jira] [Commented] (FLINK-15795) KubernetesClusterDescriptor seems to report unreachable JobManager interface URL

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086424#comment-17086424 ] Canbin Zheng commented on FLINK-15795: -- Thanks for the pointer, [~trohrmann]. I add

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

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17196: - Summary: Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint (was: Rework the

[jira] [Updated] (FLINK-17196) Rework the implementation of Fabric8FlinkKubeClient#getRestEndpoint

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17196: - Description: Currently there are some bugs in the {{Fabric8FlinkKubeClient#getRestEndpoint}} an

[jira] [Updated] (FLINK-17196) Rework the implementation of Fabric8FlinkKubeClient#getRestEndpoint

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17196: - Description: Currently there are some bugs in the This is the umbrella issue for the rework of

[jira] [Updated] (FLINK-17196) Rework the implementation of Fabric8FlinkKubeClient#getRestEndpoint

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17196: - Description: This is the umbrella issue for the rework of the implementation of {{Fabric8FlinkK

[jira] [Created] (FLINK-17232) Rethink the implicit behavior to use the Service externalIP as the address of the Endpoint

2020-04-18 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17232: Summary: Rethink the implicit behavior to use the Service externalIP as the address of the Endpoint Key: FLINK-17232 URL: https://issues.apache.org/jira/browse/FLINK-17232

[jira] [Updated] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17231: - Description: Currently, if people use the LB Service, when it comes to retrieving the Endpoint

[jira] [Created] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

2020-04-18 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17231: Summary: Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service Key: FLINK-17231 URL: https://issues.apache.org/jira/browse/FLINK-17231

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

2020-04-18 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17230: Summary: Fix incorrect returned address of Endpoint for the ClusterIP Service Key: FLINK-17230 URL: https://issues.apache.org/jira/browse/FLINK-17230 Project: Flink

[jira] [Updated] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

2020-04-18 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16601: - Parent: FLINK-17196 Issue Type: Sub-task (was: Bug) > Correct the way to get Endpoint a

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085442#comment-17085442 ] Canbin Zheng edited comment on FLINK-17177 at 4/17/20, 5:22 AM: --

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085442#comment-17085442 ] Canbin Zheng commented on FLINK-17177: -- {quote}I post the {{WatchEvent}} in K8s her

[jira] [Comment Edited] (FLINK-15795) KubernetesClusterDescriptor seems to report unreachable JobManager interface URL

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085390#comment-17085390 ] Canbin Zheng edited comment on FLINK-15795 at 4/17/20, 3:55 AM: --

[jira] [Commented] (FLINK-15795) KubernetesClusterDescriptor seems to report unreachable JobManager interface URL

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085390#comment-17085390 ] Canbin Zheng commented on FLINK-15795: -- I noticed this problem before, it is in the

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085383#comment-17085383 ] Canbin Zheng edited comment on FLINK-17176 at 4/17/20, 3:08 AM: --

[jira] [Created] (FLINK-17196) Rework the implementation of Fabric8FlinkKubeClient#getRestEndpoint

2020-04-16 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17196: Summary: Rework the implementation of Fabric8FlinkKubeClient#getRestEndpoint Key: FLINK-17196 URL: https://issues.apache.org/jira/browse/FLINK-17196 Project: Flink

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085383#comment-17085383 ] Canbin Zheng commented on FLINK-17176: -- Of course, they should share the same retry

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17177: - Description: Currently, once we receive an *ERROR* event that is sent from the K8s API server vi

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17176: - Description: In the native K8s setups, there are some cases that we do not control the speed of

[jira] [Commented] (FLINK-17183) the 'create table [if not exists]' syntax is not supported

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084689#comment-17084689 ] Canbin Zheng commented on FLINK-17183: -- It seems that we already have a plan for th

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17177: - Description: Currently, once we receive an *ERROR* event that is sent from the K8s API server vi

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

2020-04-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084629#comment-17084629 ] Canbin Zheng commented on FLINK-17176: -- {color:#0e101a}Thanks for the timely feedba

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

2020-04-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17177: - Description: Currently, once we receive an *ERROR* event that is sent from the K8s API server vi

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

2020-04-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17177: - Summary: Handle ERROR event correctly in KubernetesResourceManager#onError (was: Handle Pod ERR

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

2020-04-15 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17177: Summary: Handle Pod ERROR event correctly in KubernetesResourceManager#onError Key: FLINK-17177 URL: https://issues.apache.org/jira/browse/FLINK-17177 Project: Flink

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

2020-04-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17176: - Summary: Slow down Pod re-creation in KubernetesResourceManager#PodCallbackHandler (was: Slow d

[jira] [Created] (FLINK-17176) Slow down Pod recreation in KubernetesResourceManager#PodCallbackHandler

2020-04-15 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17176: Summary: Slow down Pod recreation in KubernetesResourceManager#PodCallbackHandler Key: FLINK-17176 URL: https://issues.apache.org/jira/browse/FLINK-17176 Project: Fli

[jira] [Commented] (FLINK-14964) Support configure remote flink jar

2020-04-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084151#comment-17084151 ] Canbin Zheng commented on FLINK-14964: -- It's a good improvement in native Kubernete

[jira] [Updated] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

2020-04-13 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16601: - Description: Currently, if one sets the type of the rest-service to {{NodePort}}, then the way

[jira] [Commented] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

2020-04-13 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082200#comment-17082200 ] Canbin Zheng commented on FLINK-17116: -- Does it related to FLINK-16788 ? > support

[jira] [Comment Edited] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

2020-04-13 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082200#comment-17082200 ] Canbin Zheng edited comment on FLINK-17116 at 4/13/20, 10:02 AM: -

[jira] [Created] (FLINK-17104) Support registering custom JobStatusListeners from config

2020-04-12 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17104: Summary: Support registering custom JobStatusListeners from config Key: FLINK-17104 URL: https://issues.apache.org/jira/browse/FLINK-17104 Project: Flink Iss

[jira] [Created] (FLINK-17102) Add -Dkubernetes.container.image= for the start-flink-session section

2020-04-12 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17102: Summary: Add -Dkubernetes.container.image= for the start-flink-session section Key: FLINK-17102 URL: https://issues.apache.org/jira/browse/FLINK-17102 Project: Flink

[jira] [Created] (FLINK-17100) Document Native Kubernetes Improvements

2020-04-12 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17100: Summary: Document Native Kubernetes Improvements Key: FLINK-17100 URL: https://issues.apache.org/jira/browse/FLINK-17100 Project: Flink Issue Type: Improveme

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

2020-04-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15648: - Summary: Support to configure limit for CPU requirement (was: Support to configure request or l

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

2020-04-10 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17090: Summary: Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU Key: FLINK-17090 URL: https://issues.apache.org/jira/browse/FLINK-17090 Project: Flink

[jira] [Updated] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes

2020-04-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17087: - Affects Version/s: 1.10.0 > Use constant port for rest.port when it's set as 0 on Kubernetes > -

[jira] [Created] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes

2020-04-10 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17087: Summary: Use constant port for rest.port when it's set as 0 on Kubernetes Key: FLINK-17087 URL: https://issues.apache.org/jira/browse/FLINK-17087 Project: Flink

[jira] [Updated] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes

2020-04-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17087: - Description: If people set {{rest.port}} to 0 when deploying a native K8s session cluster as th

[jira] [Commented] (FLINK-15641) Support to start init container

2020-04-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080403#comment-17080403 ] Canbin Zheng commented on FLINK-15641: -- [~ouyangwuli], [~fly_in_gis] Since now it i

[jira] [Commented] (FLINK-15641) Support to start init container

2020-04-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080400#comment-17080400 ] Canbin Zheng commented on FLINK-15641: -- [~fly_in_gis] Glad to reach consensus on th

[jira] [Commented] (FLINK-17070) Kubernetes session CLI ignores stop/help command in detached mode

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080184#comment-17080184 ] Canbin Zheng commented on FLINK-17070: -- Hi [~chesnay]! Could this be a subtask of F

[jira] [Commented] (FLINK-17071) Kubernetes session CLI logging output is either misleading or concerning

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080185#comment-17080185 ] Canbin Zheng commented on FLINK-17071: -- Hi [~chesnay]! Could this be a subtask of F

[jira] [Updated] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17078: - Parent: FLINK-15856 Issue Type: Sub-task (was: Bug) > Logging output is misleading when

[jira] [Updated] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17078: - Description: When executing the following command: {code:java} ./bin/flink run -d -e kubernetes-

[jira] [Created] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id

2020-04-09 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17078: Summary: Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id Key: FLINK-17078 URL: https://issues.apache.org/jira/browse/FLIN

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

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15843: - Parent: (was: FLINK-15788) Issue Type: Improvement (was: Sub-task) > Gracefully shu

[jira] [Comment Edited] (FLINK-17008) Handle null value for HADOOP_CONF_DIR/HADOOP_HOME env in AbstractKubernetesParameters#getLocalHadoopConfigurationDirectory

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079209#comment-17079209 ] Canbin Zheng edited comment on FLINK-17008 at 4/9/20, 11:21 AM: --

[jira] [Commented] (FLINK-17008) Handle null value for HADOOP_CONF_DIR/HADOOP_HOME env in AbstractKubernetesParameters#getLocalHadoopConfigurationDirectory

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079209#comment-17079209 ] Canbin Zheng commented on FLINK-17008: -- Hi, [~chesnay]. If both *{color:#172b4d}EN

[jira] [Comment Edited] (FLINK-16521) Remove unused FileUtils#isClassFile

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079141#comment-17079141 ] Canbin Zheng edited comment on FLINK-16521 at 4/9/20, 10:04 AM: --

[jira] [Commented] (FLINK-16521) Remove unused FileUtils#isClassFile

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079141#comment-17079141 ] Canbin Zheng commented on FLINK-16521: -- Hi, [~maguowei], could you help check it?

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

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079055#comment-17079055 ] Canbin Zheng commented on FLINK-15656: -- [~fly_in_gis] Thanks for giving me more pat

[jira] [Comment Edited] (FLINK-15641) Support to start init container

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079048#comment-17079048 ] Canbin Zheng edited comment on FLINK-15641 at 4/9/20, 8:23 AM: ---

[jira] [Commented] (FLINK-15641) Support to start init container

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079048#comment-17079048 ] Canbin Zheng commented on FLINK-15641: -- Ah, #1 solves my original question. For #2

[jira] [Commented] (FLINK-15642) Support to set JobManager readiness and liveness check

2020-04-09 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079040#comment-17079040 ] Canbin Zheng commented on FLINK-15642: -- Sounds reasonable. One thing to confirm, wh

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

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078853#comment-17078853 ] Canbin Zheng commented on FLINK-15656: -- [~ouyangwuli], [~fly_in_gis] The built-in i

[jira] [Commented] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078847#comment-17078847 ] Canbin Zheng commented on FLINK-17055: -- Thanks for the explanation [~tison], [~kkl0

[jira] [Closed] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-17055. Resolution: Not A Problem > List jobs via bin/flink throws FlinkException indicating no cluster id

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid  ap

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid  ap

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid  ap

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid  ap

[jira] [Created] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

2020-04-08 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17055: Summary: List jobs via bin/flink throws FlinkException indicating no cluster id was specified Key: FLINK-17055 URL: https://issues.apache.org/jira/browse/FLINK-17055

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

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078086#comment-17078086 ] Canbin Zheng commented on FLINK-15656: -- Hi [~ouyangwuli]. Could you provide a proto

[jira] [Updated] (FLINK-17033) Upgrade OpenJDK docker image for Kubernetes

2020-04-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17033: - Description: The current docker image {{openjdk:8-jre-alpine}} used by Kubernetes has many prob

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

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077827#comment-17077827 ] Canbin Zheng edited comment on FLINK-15656 at 4/8/20, 4:45 AM: ---

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

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077827#comment-17077827 ] Canbin Zheng commented on FLINK-15656: -- >> I think it makes sense to me to provide

[jira] [Commented] (FLINK-10934) Support per-job mode in kubernetes

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077826#comment-17077826 ] Canbin Zheng commented on FLINK-10934: -- Thanks for the explanation [~fly_in_gis]. I

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

2020-04-07 Thread Canbin Zheng (Jira)
[ 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 c

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

2020-04-07 Thread Canbin Zheng (Jira)
[ 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 c

[jira] [Commented] (FLINK-10934) Support per-job mode in kubernetes

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077295#comment-17077295 ] Canbin Zheng commented on FLINK-10934: -- Hi [~fly_in_gis]! Could you share more deta

[jira] [Commented] (FLINK-12160) Support to ship user config files on kubernetes

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077292#comment-17077292 ] Canbin Zheng commented on FLINK-12160: -- Ah, I see! > Support to ship user config f

[jira] [Commented] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077276#comment-17077276 ] Canbin Zheng commented on FLINK-16913: -- Thanks for the quick fix and the explanatio

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

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077214#comment-17077214 ] Canbin Zheng commented on FLINK-15843: -- {code:java} kubectl exec -it flink-native-k

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

2020-04-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077139#comment-17077139 ] Canbin Zheng commented on FLINK-15843: -- Hi [~fly_in_gis]. Could you help check whet

[jira] [Created] (FLINK-17034) Execute the container CMD under TINI for better hygiene

2020-04-07 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17034: Summary: Execute the container CMD under TINI for better hygiene Key: FLINK-17034 URL: https://issues.apache.org/jira/browse/FLINK-17034 Project: Flink Issu

[jira] [Created] (FLINK-17033) Upgrade OpenJDK docker image for Kubernetes

2020-04-07 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17033: Summary: Upgrade OpenJDK docker image for Kubernetes Key: FLINK-17033 URL: https://issues.apache.org/jira/browse/FLINK-17033 Project: Flink Issue Type: Impro

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

2020-04-07 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17032: Summary: Naming convention unification for all the Kubernetes Resources Key: FLINK-17032 URL: https://issues.apache.org/jira/browse/FLINK-17032 Project: Flink

[jira] [Comment Edited] (FLINK-12160) Support to ship user config files on kubernetes

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076884#comment-17076884 ] Canbin Zheng edited comment on FLINK-12160 at 4/7/20, 4:14 AM: ---

[jira] [Comment Edited] (FLINK-12160) Support to ship user config files on kubernetes

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076884#comment-17076884 ] Canbin Zheng edited comment on FLINK-12160 at 4/7/20, 4:13 AM: ---

[jira] [Commented] (FLINK-12160) Support to ship user config files on kubernetes

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076884#comment-17076884 ] Canbin Zheng commented on FLINK-12160: -- Thanks [~fly_in_gis]! I checked again the d

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

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15843: - Summary: Gracefully shutdown TaskManagers on Kubernetes (was: Do not violently kill TaskManager

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

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

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

2020-04-06 Thread Canbin Zheng (Jira)
[ 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-15788) Issue Type: New Feature (was: Sub-task) > Support to con

[jira] [Updated] (FLINK-15843) Do not violently kill TaskManagers on Kubernetes

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15843: - Description: The current solution of stopping a TaskManager instance when JobManager sends a de

[jira] [Commented] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076314#comment-17076314 ] Canbin Zheng commented on FLINK-16601: -- Hi [~fly_in_gis]! It sounds reasonable to i

[jira] [Created] (FLINK-17008) Handle null value for HADOOP_CONF_DIR/HADOOP_HOME env in AbstractKubernetesParameters#getLocalHadoopConfigurationDirectory

2020-04-06 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17008: Summary: Handle null value for HADOOP_CONF_DIR/HADOOP_HOME env in AbstractKubernetesParameters#getLocalHadoopConfigurationDirectory Key: FLINK-17008 URL: https://issues.apache.org

[jira] [Commented] (FLINK-15642) Support to set JobManager liveness check

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076209#comment-17076209 ] Canbin Zheng commented on FLINK-15642: -- Hi [~fly_in_gis]! I am not sure whether we

[jira] [Commented] (FLINK-12160) Support to ship user config files on kubernetes

2020-04-06 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076100#comment-17076100 ] Canbin Zheng commented on FLINK-12160: -- Hi [~fly_in_gis]! Thanks for filing this is

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

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16624: - Parent: FLINK-14460 Issue Type: Sub-task (was: Improvement) > Support user-specified an

[jira] [Closed] (FLINK-15822) Rethink the necessity of the internal Service

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-15822. Fix Version/s: (was: 1.10.1) Resolution: Fixed > Rethink the necessity of the internal

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

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16602: - Summary: Rework the Service design for native Kubernetes deployment (was: Rework the Service de

<    1   2   3   4   5   >