[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936351#comment-15936351 ] CanBin Zheng commented on FLINK-6159: - I just found RemoteExecutionEnvironment can sub

[jira] [Closed] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CanBin Zheng closed FLINK-6159. --- Resolution: Not A Problem > Add Java/Scala FlinkLauncher > > >

[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936379#comment-15936379 ] CanBin Zheng commented on FLINK-6159: - Agree, another question: RemoteExecEnv directly

[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937512#comment-15937512 ] CanBin Zheng commented on FLINK-6159: - Got it, tks > Add Java/Scala FlinkLauncher > -

[jira] [Commented] (FLINK-6148) The Zookeeper client occur SASL error when the sasl is disable

2017-03-24 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941537#comment-15941537 ] CanBin Zheng commented on FLINK-6148: - This is a reduplicate issue, I have reported th

[jira] [Created] (FLINK-6186) Remove unused import

2017-03-24 Thread CanBin Zheng (JIRA)
CanBin Zheng created FLINK-6186: --- Summary: Remove unused import Key: FLINK-6186 URL: https://issues.apache.org/jira/browse/FLINK-6186 Project: Flink Issue Type: Wish Reporter: CanBi

[jira] [Updated] (FLINK-6186) Remove unused import

2017-03-24 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CanBin Zheng updated FLINK-6186: Description: Remove unused import org.apache.flink.api.java.ExecutionEnvironment in org.apache.flin

[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-25 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941633#comment-15941633 ] CanBin Zheng commented on FLINK-6159: - [~StephanEwen] I'd like to have a try, it dese

[jira] [Created] (FLINK-6224) RemoteStreamEnvironment not resolve hostname of JobManager

2017-03-30 Thread CanBin Zheng (JIRA)
CanBin Zheng created FLINK-6224: --- Summary: RemoteStreamEnvironment not resolve hostname of JobManager Key: FLINK-6224 URL: https://issues.apache.org/jira/browse/FLINK-6224 Project: Flink Issue

[jira] [Updated] (FLINK-6224) RemoteStreamEnvironment not resolve hostname of JobManager

2017-03-30 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CanBin Zheng updated FLINK-6224: Description: I run two examples in the same client. first one use ExecutionEnvironment.cre

[jira] [Updated] (FLINK-6224) RemoteStreamEnvironment not resolve ip of JobManager to hostname

2017-03-30 Thread CanBin Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CanBin Zheng updated FLINK-6224: Summary: RemoteStreamEnvironment not resolve ip of JobManager to hostname (was: RemoteStreamEnviron

[jira] [Created] (FLINK-6269) var could be a val

2017-04-05 Thread CanBin Zheng (JIRA)
CanBin Zheng created FLINK-6269: --- Summary: var could be a val Key: FLINK-6269 URL: https://issues.apache.org/jira/browse/FLINK-6269 Project: Flink Issue Type: Wish Components: JobMana

[jira] [Created] (FLINK-14075) Remove unnecessary resource close in JDBCOutputFormatTest.java

2019-09-13 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14075: Summary: Remove unnecessary resource close in JDBCOutputFormatTest.java Key: FLINK-14075 URL: https://issues.apache.org/jira/browse/FLINK-14075 Project: Flink

[jira] [Closed] (FLINK-14075) Remove unnecessary resource close in JDBCOutputFormatTest.java

2019-09-13 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-14075. Release Note: Method has been removed in master branch. Resolution: Resolved > Remove unnece

[jira] [Created] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-15 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14078: Summary: Introduce more JDBCDialect implementations Key: FLINK-14078 URL: https://issues.apache.org/jira/browse/FLINK-14078 Project: Flink Issue Type: New Fe

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930260#comment-16930260 ] Canbin Zheng commented on FLINK-14078: -- Hi, [~lzljs3620320]  I'd like to work on th

[jira] [Created] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

2019-09-17 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14098: Summary: Support multiple sql statements splitting by semicolon for TableEnvironment Key: FLINK-14098 URL: https://issues.apache.org/jira/browse/FLINK-14098 Project:

[jira] [Updated] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

2019-09-17 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14098: - Component/s: Table SQL / API > Support multiple sql statements splitting by semicolon for TableE

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

2019-09-17 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14100: Summary: Introduce OracleDialect Key: FLINK-14100 URL: https://issues.apache.org/jira/browse/FLINK-14100 Project: Flink Issue Type: Sub-task Repo

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

2019-09-17 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14101: Summary: Introduce SqlServerDialect Key: FLINK-14101 URL: https://issues.apache.org/jira/browse/FLINK-14101 Project: Flink Issue Type: Sub-task R

[jira] [Created] (FLINK-14102) Introduce DB2Dialect

2019-09-17 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14102: Summary: Introduce DB2Dialect Key: FLINK-14102 URL: https://issues.apache.org/jira/browse/FLINK-14102 Project: Flink Issue Type: Sub-task Reporte

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-17 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931959#comment-16931959 ] Canbin Zheng commented on FLINK-14078: -- [~ykt836]  [~lzljs3620320] Yes, so there's

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-17 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931980#comment-16931980 ] Canbin Zheng commented on FLINK-14078: -- Thanks for the quick response [~ykt836] !

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

2019-09-17 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931999#comment-16931999 ] Canbin Zheng commented on FLINK-14099: -- +1.  I think Computed column is a more gene

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

2019-09-17 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931999#comment-16931999 ] Canbin Zheng edited comment on FLINK-14099 at 9/18/19 3:08 AM: ---

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

2019-09-17 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931999#comment-16931999 ] Canbin Zheng edited comment on FLINK-14099 at 9/18/19 3:09 AM: ---

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-17 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932048#comment-16932048 ] Canbin Zheng commented on FLINK-14078: -- Thanks [~ykt836] ! > Introduce more JDBCDi

[jira] [Commented] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

2019-09-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935684#comment-16935684 ] Canbin Zheng commented on FLINK-14098: -- Thanks [~jark]  [~xuefuz] for your response

[jira] [Updated] (FLINK-14098) Support multiple statements for TableEnvironment

2019-09-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14098: - Summary: Support multiple statements for TableEnvironment (was: Support multiple statements spl

[jira] [Updated] (FLINK-14098) Support multiple statements splitting for TableEnvironment

2019-09-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14098: - Summary: Support multiple statements splitting for TableEnvironment (was: Support multiple sql

[jira] [Commented] (FLINK-13734) Support DDL in SQL CLI

2019-09-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935694#comment-16935694 ] Canbin Zheng commented on FLINK-13734: -- +1 for this feature, seems to be a subtask

[jira] [Commented] (FLINK-14098) Support multiple statements for TableEnvironment

2019-09-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935732#comment-16935732 ] Canbin Zheng commented on FLINK-14098: -- Thanks for quick response [~jark] ! Could y

[jira] [Created] (FLINK-14171) Add 'SHOW USER FUNCTIONS' support in SQL CLI

2019-09-23 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14171: Summary: Add 'SHOW USER FUNCTIONS' support in SQL CLI Key: FLINK-14171 URL: https://issues.apache.org/jira/browse/FLINK-14171 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-14171) Add 'SHOW USER FUNCTIONS' support in SQL CLI

2019-09-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14171: - Description: Currently *listUserDefinedFunctions* has been supported in Executor, I think we can

[jira] [Created] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-23 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14179: Summary: Wrong description of SqlCommand.SHOW_FUNCTIONS Key: FLINK-14179 URL: https://issues.apache.org/jira/browse/FLINK-14179 Project: Flink Issue Type: Bu

[jira] [Resolved] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-24 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng resolved FLINK-14179. -- Resolution: Fixed > Wrong description of SqlCommand.SHOW_FUNCTIONS > -

[jira] [Reopened] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng reopened FLINK-14179: -- Not merged yet. > Wrong description of SqlCommand.SHOW_FUNCTIONS > --

[jira] [Commented] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940248#comment-16940248 ] Canbin Zheng commented on FLINK-14179: -- [~Tison] [~jark] It's a quite minor change,

[jira] [Updated] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14179: - Attachment: image-2019-09-29-14-29-02-274.png > Wrong description of SqlCommand.SHOW_FUNCTIONS >

[jira] [Updated] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14179: - Attachment: image-2019-09-29-14-29-54-861.png > Wrong description of SqlCommand.SHOW_FUNCTIONS >

[jira] [Updated] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14179: - Description: Currently '*SHOW FUNCTIONS*' lists not only user-defined functions, but also syste

[jira] [Updated] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14179: - Description: Currently '*SHOW FUNCTIONS*' lists not only user-defined functions, but also syste

[jira] [Updated] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14179: - Attachment: image-2019-09-29-14-34-45-151.png > Wrong description of SqlCommand.SHOW_FUNCTIONS >

[jira] [Commented] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940259#comment-16940259 ] Canbin Zheng commented on FLINK-14179: -- Thanks [~tison] > Wrong description of Sql

[jira] [Commented] (FLINK-16833) Make JDBCDialect pluggable for JDBC SQL connector

2020-03-27 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069189#comment-17069189 ] Canbin Zheng commented on FLINK-16833: -- +1 for this feature. > Make JDBCDialect pl

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

2020-03-29 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-16855: Summary: Update K8s template for the standalone setup Key: FLINK-16855 URL: https://issues.apache.org/jira/browse/FLINK-16855 Project: Flink Issue Type: Impr

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

2020-03-29 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16855: - Description: Following FLINK-16602 and discussion in  [https://github.com/apache/flink/pull/11456

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

2020-03-31 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071603#comment-17071603 ] Canbin Zheng commented on FLINK-15656: -- [~fly_in_gis] Thanks a lot for sharing the

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

2020-03-31 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15816: - Fix Version/s: (was: 1.10.1) > Limit the maximum length of the value of kubernetes.cluster-i

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

2020-03-31 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071611#comment-17071611 ] Canbin Zheng commented on FLINK-15816: -- [~fly_in_gis] Seems that we have enough tim

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

2020-04-01 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-16913: Summary: ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException Key: FLINK-16913 URL: https://issues.apache.org/jira/browse/FLINK-16913 Pro

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

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16913: - Description: Steps to reproduce the issue: # Set flink-conf.yaml ** state.backend: rocksdb **

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

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16913: - Description: Steps to reproduce the issue: # Set flink-conf.yaml ** state.backend: rocksdb **

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

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16913: - Issue Type: Bug (was: Improvement) > ReadableConfigToConfigurationAdapter#getEnum throws > Uns

[jira] [Commented] (FLINK-16921) "kubernetes session test" is unstable

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073287#comment-17073287 ] Canbin Zheng commented on FLINK-16921: -- Though I haven't inspected the details, it

[jira] [Comment Edited] (FLINK-16921) "kubernetes session test" is unstable

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073287#comment-17073287 ] Canbin Zheng edited comment on FLINK-16921 at 4/2/20, 1:19 AM: ---

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

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16913: - Description: Steps to reproduce the issue: # Set flink-conf.yaml ** state.backend: rocksdb **

[jira] [Commented] (FLINK-14787) Add configure method to StreamExecutionEnvironment

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073382#comment-17073382 ] Canbin Zheng commented on FLINK-14787: -- Hi [~dwysakowicz]! Could you help take a lo

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

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076019#comment-17076019 ] Canbin Zheng commented on FLINK-15656: -- [~fly_in_gis] Sorry for the late reply. Th

[jira] [Updated] (FLINK-15646) Configurable K8s context support

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15646: - Parent: (was: FLINK-15788) Issue Type: New Feature (was: Sub-task) > Configurable K

[jira] [Updated] (FLINK-15646) Configurable K8s context support

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15646: - Parent: FLINK-14460 Issue Type: Sub-task (was: New Feature) > Configurable K8s context

[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: - Parent: FLINK-14460 Issue Type: Sub-task (was: Improvement) > Rework the Service design

[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

[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-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] [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] [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] [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-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] [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] [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-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-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] [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] [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] [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] [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] [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-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] [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] [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-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-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-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] [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=17077826#comment-17077826 ] Canbin Zheng commented on FLINK-10934: -- Thanks for the explanation [~fly_in_gis]. I

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

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

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

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

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

2020-05-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104007#comment-17104007 ] Canbin Zheng commented on FLINK-17565: -- Hi [~tison]! At the moment this ticket fir

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

2020-05-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104040#comment-17104040 ] Canbin Zheng commented on FLINK-17598: -- [~fly_in_gis] Not exactly. The *StatefulSet

  1   2   3   4   5   >