[jira] [Created] (FLINK-15843) Do not violently kill TaskManagers

2020-02-02 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-15843: Summary: Do not violently kill TaskManagers Key: FLINK-15843 URL: https://issues.apache.org/jira/browse/FLINK-15843 Project: Flink Issue Type: Sub-task

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

2020-02-02 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] [Updated] (FLINK-15843) Do not violently kill TaskManagers

2020-02-02 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] [Updated] (FLINK-15843) Do not violently kill TaskManagers

2020-02-02 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] [Created] (FLINK-15852) Job is submitted to the wrong session cluster

2020-02-02 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-15852: Summary: Job is submitted to the wrong session cluster Key: FLINK-15852 URL: https://issues.apache.org/jira/browse/FLINK-15852 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-15852) Job is submitted to the wrong session cluster

2020-02-02 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15852: - Description: Steps to reproduce the problem: # Deploy a YARN session cluster by command {{./bin

[jira] [Created] (FLINK-15856) Various Kubernetes command client improvements

2020-02-02 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-15856: Summary: Various Kubernetes command client improvements Key: FLINK-15856 URL: https://issues.apache.org/jira/browse/FLINK-15856 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-15857) Support --help for the kubernetes-session script

2020-02-02 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-15857: Summary: Support --help for the kubernetes-session script Key: FLINK-15857 URL: https://issues.apache.org/jira/browse/FLINK-15857 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15852) Job is submitted to the wrong session cluster

2020-02-03 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029422#comment-17029422 ] Canbin Zheng commented on FLINK-15852: -- Yep it may have to do with the yarn-properp

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

2020-02-03 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029433#comment-17029433 ] Canbin Zheng commented on FLINK-15843: -- {color:#0e101a}Well it depends, if all temp

[jira] [Commented] (FLINK-15816) Limit the maximum length of the value of kubernetes.cluster-id configuration option

2020-02-03 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029491#comment-17029491 ] Canbin Zheng commented on FLINK-15816: -- Hi [~fly_in_gis] I think it would be good t

[jira] [Commented] (FLINK-15666) GPU scheduling support in Kubernetes mode

2020-02-03 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029494#comment-17029494 ] Canbin Zheng commented on FLINK-15666: -- Got it, thanks [~karmagyz] ! > GPU schedul

[jira] [Commented] (FLINK-15856) Various Kubernetes command client improvements

2020-02-03 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029496#comment-17029496 ] Canbin Zheng commented on FLINK-15856: -- Thanks for the information [~fly_in_gis] !

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

2020-02-03 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029510#comment-17029510 ] Canbin Zheng commented on FLINK-15641: -- Hi [~fly_in_gis], It seems that the init-co

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

2020-02-03 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029510#comment-17029510 ] Canbin Zheng edited comment on FLINK-15641 at 2/4/20 3:05 AM:

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

2020-08-26 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185032#comment-17185032 ] Canbin Zheng commented on FLINK-17273: -- Hi [~xintongsong], I do not work on this is

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

2020-08-31 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187667#comment-17187667 ] Canbin Zheng commented on FLINK-17480: -- Hi [~csq], [~fly_in_gis].  Feel free to tak

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

2020-05-19 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111672#comment-17111672 ] Canbin Zheng commented on FLINK-17565: -- Updates: Since the fabric8 kubernetes-clie

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

2020-05-25 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116363#comment-17116363 ] Canbin Zheng commented on FLINK-17565: -- [~zjwang] 1.11 has supported application mo

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

2020-05-25 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116369#comment-17116369 ] Canbin Zheng commented on FLINK-17230: -- [~zjwang] The scope of this problem is that

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

2020-05-25 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116389#comment-17116389 ] Canbin Zheng commented on FLINK-17565: -- Thank you [~zjwang]. [~tison]  Should I ma

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

2020-05-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118563#comment-17118563 ] Canbin Zheng commented on FLINK-17230: -- > [~felixzheng] Could you open a PR to back

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

2020-05-28 Thread Canbin Zheng (Jira)
[ 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 returned

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

2020-05-28 Thread Canbin Zheng (Jira)
[ 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 S

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

2020-05-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119193#comment-17119193 ] Canbin Zheng commented on FLINK-17230: -- > I think it makes sense to cover it in rel

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

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

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

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

2020-04-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091156#comment-17091156 ] Canbin Zheng commented on FLINK-17273: -- Thanks a lot for the input [~trohrmann] [~x

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

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

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

2020-04-24 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091413#comment-17091413 ] Canbin Zheng commented on FLINK-17100: -- {quote}do you mean in the title "Improvemen

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

2020-04-24 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-24 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-17032) Naming convention unification for all the Kubernetes Resources

2020-04-24 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091491#comment-17091491 ] Canbin Zheng commented on FLINK-17032: -- {quote}Another property that I would consid

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

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

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

2020-04-25 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092438#comment-17092438 ] Canbin Zheng commented on FLINK-17382: -- Is it a duplicate of  FLINK-16478 ? > Flin

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

2020-04-25 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092473#comment-17092473 ] Canbin Zheng commented on FLINK-16478: -- [~xiaodao] [~dixingx...@yeah.net] Would it

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

2020-04-27 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094071#comment-17094071 ] Canbin Zheng commented on FLINK-16478: -- {quote}[~felixzheng] yes, that depends on h

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

2020-04-27 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094076#comment-17094076 ] Canbin Zheng commented on FLINK-16478: -- In addition to the rest API support, could

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

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

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

2020-04-30 Thread Canbin Zheng (Jira)
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 Fe

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

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

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

2020-04-30 Thread Canbin Zheng (Jira)
[ 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. (was:

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

2020-05-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099604#comment-17099604 ] Canbin Zheng commented on FLINK-17509: -- Is it a duplicate of FLINK-14100 ? > Suppo

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

2020-05-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099633#comment-17099633 ] Canbin Zheng commented on FLINK-17515: -- Not very sure whether the file uploading fu

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

2020-05-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099639#comment-17099639 ] Canbin Zheng commented on FLINK-14100: --  Not sure whether I have enough time for th

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

2020-05-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099658#comment-17099658 ] Canbin Zheng commented on FLINK-17515: -- I got it. Thanks for the explanation [~kkl0

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

2020-05-06 Thread Canbin Zheng (Jira)
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-17549) Support running Stateful Functions on native Kubernetes setup

2020-05-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102149#comment-17102149 ] Canbin Zheng commented on FLINK-17549: -- HI [~igal]! Currently, it is a feature requ

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

2020-05-07 Thread Canbin Zheng (Jira)
[ 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-16508) Name the ports exposed by the main Container in Pod

2020-05-07 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102154#comment-17102154 ] Canbin Zheng commented on FLINK-16508: -- Hi [~tison] ! Sorry that I don't backport t

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

2020-05-07 Thread Canbin Zheng (Jira)
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: Improve

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

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

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

2020-05-07 Thread Canbin Zheng (Jira)
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 Project

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

2020-05-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102365#comment-17102365 ] Canbin Zheng commented on FLINK-17566: -- Not exactly. Version 4.5.2 doesn't send one

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

2020-05-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102365#comment-17102365 ] Canbin Zheng edited comment on FLINK-17566 at 5/8/20, 8:20 AM: ---

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

2020-05-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102484#comment-17102484 ] Canbin Zheng commented on FLINK-14101: -- [~f.pompermaier] Go ahead! > Introduce Sql

[jira] [Commented] (FLINK-14146) Introduce Pulsar connector

2020-05-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102517#comment-17102517 ] Canbin Zheng commented on FLINK-14146: -- +1, looking forward to faster progress of t

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

2020-05-08 Thread Canbin Zheng (Jira)
[ 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 4.9.

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

2020-05-08 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17103040#comment-17103040 ] Canbin Zheng commented on FLINK-17566: -- Right. According to the suggestion from the

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

2020-05-08 Thread Canbin Zheng (Jira)
[ 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 4.10

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

<    1   2   3   4   5   >