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

[ 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-15646) Configurable K8s context support

[ 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-15646) Configurable K8s context support

[ 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] [Commented] (FLINK-15656) Support user-specified pod templates

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

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

[ 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] [Updated] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

[ 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] [Comment Edited] (FLINK-16921) "kubernetes session test" is unstable

[ 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] [Commented] (FLINK-16921) "kubernetes session test" is unstable

[ 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] [Updated] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

[ 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] [Updated] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

[ 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] [Created] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

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

[ 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-15816) Limit the maximum length of the value of kubernetes.cluster-id configuration option

[ 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

[ 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] [Commented] (FLINK-15656) Support user-specified pod templates

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

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

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

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

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] [Commented] (FLINK-16833) Make JDBCDialect pluggable for JDBC SQL connector

[ 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] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066409#comment-17066409 ] Canbin Zheng edited comment on FLINK-16478 at 3/25/20, 6:15 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066409#comment-17066409 ] Canbin Zheng commented on FLINK-16478: -- Hi [~xiaodao]. It's better to first draft a

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

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066397#comment-17066397 ] Canbin Zheng edited comment on FLINK-16478 at 3/25/20, 5:24 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066397#comment-17066397 ] Canbin Zheng commented on FLINK-16478: -- Thanks for creating this issue, [~xiaodao].

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Canbin Zheng created FLINK-16715: Summary: Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained Key: FLINK-16715 URL: https://issues.apache.org/jira/browse/F

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

[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15648: - Fix Version/s: 1.11.0 > Support to configure request or limit for CPU requirement >

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

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

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

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

[jira] [Commented] (FLINK-16598) Respect the rest port exposed by Service in Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-16598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063882#comment-17063882 ] Canbin Zheng commented on FLINK-16598: -- Hi [~tison] [~trohrmann]. Could you help as

[jira] [Commented] (FLINK-16600) Respect the rest.bind-port for the Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-16600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063881#comment-17063881 ] Canbin Zheng commented on FLINK-16600: -- Hi [~tison] [~trohrmann]. Could you help as

[jira] [Commented] (FLINK-15625) flink sql multiple statements syntatic validation supports

[ https://issues.apache.org/jira/browse/FLINK-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063799#comment-17063799 ] Canbin Zheng commented on FLINK-15625: -- It may also be related to [FLINK-14098|htt

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

Canbin Zheng created FLINK-16699: Summary: Support accessing secured services via K8s secrets Key: FLINK-16699 URL: https://issues.apache.org/jira/browse/FLINK-16699 Project: Flink Issue Type

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063185#comment-17063185 ] Canbin Zheng commented on FLINK-16692: -- [~jackylau] We need this feature too, glad

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063159#comment-17063159 ] Canbin Zheng commented on FLINK-16692: -- Hi, [~jackylau]! Do you have an implementat

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

[ https://issues.apache.org/jira/browse/FLINK-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16625: - Summary: Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUti

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

[ https://issues.apache.org/jira/browse/FLINK-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16625: - Description: {{BootstrapTools#getEnvironmentVariables}} actually is a general utility to extrac

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

[ https://issues.apache.org/jira/browse/FLINK-15852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063021#comment-17063021 ] Canbin Zheng commented on FLINK-15852: -- Thanks for the fixup [~kkl0u]! > Job is su

[jira] [Commented] (FLINK-15639) Support to set toleration for jobmanager and taskmanger

[ https://issues.apache.org/jira/browse/FLINK-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062348#comment-17062348 ] Canbin Zheng commented on FLINK-15639: -- [~fly_in_gis] Thanks for the explanation! S

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

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059924#comment-17059924 ] Canbin Zheng edited comment on FLINK-16602 at 3/19/20, 3:48 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060607#comment-17060607 ] Canbin Zheng edited comment on FLINK-16602 at 3/19/20, 3:40 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1706#comment-1706 ] Canbin Zheng edited comment on FLINK-16601 at 3/19/20, 1:53 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1706#comment-1706 ] Canbin Zheng commented on FLINK-16601: -- Hi, [~fly_in_gis]! Personally I prefer not

[jira] [Commented] (FLINK-15639) Support to set toleration for jobmanager and taskmanger

[ https://issues.apache.org/jira/browse/FLINK-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062220#comment-17062220 ] Canbin Zheng commented on FLINK-15639: -- Hi [~fly_in_gis]! It seems that this ticke

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

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060860#comment-17060860 ] Canbin Zheng edited comment on FLINK-15871 at 3/17/20, 12:11 PM: -

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060860#comment-17060860 ] Canbin Zheng commented on FLINK-15871: -- Hi, [~ouyangwuli]! In our internal version

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060157#comment-17060157 ] Canbin Zheng commented on FLINK-16547: -- Thanks, [~kkl0u]! I will attach a PR this w

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

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060111#comment-17060111 ] Canbin Zheng edited comment on FLINK-15871 at 3/16/20, 10:48 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060111#comment-17060111 ] Canbin Zheng commented on FLINK-15871: -- I think the sidecar container needs depth d

[jira] [Updated] (FLINK-15667) Support to mount Hadoop Configurations

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15667: - Description: Mounts the Hadoop configurations, either as a pre-defined config map, or a local c

[jira] [Updated] (FLINK-15667) Support to mount Hadoop Configurations

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15667: - Summary: Support to mount Hadoop Configurations (was: Hadoop Configurations Mount Support) > S

[jira] [Updated] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16547: - Summary: Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH (was: Correct t

[jira] [Commented] (FLINK-16547) Correct the order to write temporary files in YarnClusterDescriptor#startAppMaster

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060012#comment-17060012 ] Canbin Zheng commented on FLINK-16547: -- Hi [~kkl0u], thanks a lot for the response!

[jira] [Updated] (FLINK-16600) Respect the rest.bind-port for the Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-16600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16600: - Description: Our current logic only takes care of {{RestOptions.PORT}} but not {{RestOptions.BI

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

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059932#comment-17059932 ] Canbin Zheng commented on FLINK-16601: -- Hi [~fly_in_gis].  Internally we use the K

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

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059924#comment-17059924 ] Canbin Zheng commented on FLINK-16602: -- Hi, [~fly_in_gis]. Thanks for the reponse.

[jira] [Updated] (FLINK-15667) Hadoop Configurations Mount Support

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15667: - Fix Version/s: 1.11.0 > Hadoop Configurations Mount Support > --

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

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16602: - Description: {color:#0e101a}At the moment we usually create two Services for a Flink applicatio

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

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059570#comment-17059570 ] Canbin Zheng commented on FLINK-16602: -- cc [~tison], [~trohrmann], [~fly_in_gis].

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

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16602: - Description: {color:#0e101a}At the moment we usually create two Services for a Flink applicatio

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

Canbin Zheng created FLINK-16602: Summary: Rework the Service design for Kubernetes deployment Key: FLINK-16602 URL: https://issues.apache.org/jira/browse/FLINK-16602 Project: Flink Issue Typ

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

Canbin Zheng created FLINK-16601: Summary: Corret the way to get Endpoint address for NodePort rest Service Key: FLINK-16601 URL: https://issues.apache.org/jira/browse/FLINK-16601 Project: Flink

[jira] [Created] (FLINK-16600) Respect the rest.bind-port for the Kubernetes setup

Canbin Zheng created FLINK-16600: Summary: Respect the rest.bind-port for the Kubernetes setup Key: FLINK-16600 URL: https://issues.apache.org/jira/browse/FLINK-16600 Project: Flink Issue Typ

[jira] [Updated] (FLINK-16598) Respect the rest port exposed by Service in Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-16598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16598: - Description: Steps to reproduce the problem: # Start a Kubernetes session cluster, by default,

[jira] [Created] (FLINK-16598) Respect the rest port exposed by Service in Fabric8FlinkKubeClient#getRestEndpoint

Canbin Zheng created FLINK-16598: Summary: Respect the rest port exposed by Service in Fabric8FlinkKubeClient#getRestEndpoint Key: FLINK-16598 URL: https://issues.apache.org/jira/browse/FLINK-16598 Pr

[jira] [Commented] (FLINK-15667) Hadoop Configurations Mount Support

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059537#comment-17059537 ] Canbin Zheng commented on FLINK-15667: -- Thanks [~tison]! Will do the click when sta

[jira] [Commented] (FLINK-15667) Hadoop Configurations Mount Support

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059357#comment-17059357 ] Canbin Zheng commented on FLINK-15667: -- Hi [~tison], [~trohrmann]. Could you help a

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

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059355#comment-17059355 ] Canbin Zheng commented on FLINK-16521: -- Hi [~csbliss]. We are double checking with

[jira] [Commented] (FLINK-16547) Correct the order to write temporary files in YarnClusterDescriptor#startAppMaster

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059349#comment-17059349 ] Canbin Zheng commented on FLINK-16547: -- Hi [~kkl0u]. I agree that we don't expose t

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

[ https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057740#comment-17057740 ] Canbin Zheng edited comment on FLINK-15666 at 3/12/20, 9:21 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057740#comment-17057740 ] Canbin Zheng commented on FLINK-15666: -- Thanks for the great work! So exciting to s

[jira] [Created] (FLINK-16547) Corrent the order to write temporary files in YarnClusterDescriptor#startAppMaster

Canbin Zheng created FLINK-16547: Summary: Corrent the order to write temporary files in YarnClusterDescriptor#startAppMaster Key: FLINK-16547 URL: https://issues.apache.org/jira/browse/FLINK-16547 Pr

[jira] [Updated] (FLINK-16546) Fix logging bug in YarnClusterDescriptor#startAppMaster

[ https://issues.apache.org/jira/browse/FLINK-16546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16546: - Description: It's a minor fixup of the warning in case of tmpJobGraphFile deletion failure. Fro

[jira] [Created] (FLINK-16546) Fix logging bug in YarnClusterDescriptor#startAppMaster

Canbin Zheng created FLINK-16546: Summary: Fix logging bug in YarnClusterDescriptor#startAppMaster Key: FLINK-16546 URL: https://issues.apache.org/jira/browse/FLINK-16546 Project: Flink Issue

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

Canbin Zheng created FLINK-16521: Summary: Remove unused FileUtils#isClassFile Key: FLINK-16521 URL: https://issues.apache.org/jira/browse/FLINK-16521 Project: Flink Issue Type: Improvement

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

Canbin Zheng created FLINK-16508: Summary: Name the ports exposed by the main Container in Pod Key: FLINK-16508 URL: https://issues.apache.org/jira/browse/FLINK-16508 Project: Flink Issue Typ

[jira] [Reopened] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng reopened FLINK-16025: -- Backport the fix to 1.10.1 > Service could expose blob server port mismatched with JM Container >

[jira] [Commented] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054636#comment-17054636 ] Canbin Zheng commented on FLINK-16025: -- Thanks for the reminder [~fly_in_gis]. 1.10

[jira] [Updated] (FLINK-16494) Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

[ https://issues.apache.org/jira/browse/FLINK-16494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16494: - Description: At the moment the value of KubernetesConfigOptions.{color:#172b4d}CONTAINER_IMAGE_P

[jira] [Created] (FLINK-16494) Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

Canbin Zheng created FLINK-16494: Summary: Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY Key: FLINK-16494 URL: https://issues.apache.org/jira/browse/FLINK-16494

[jira] [Commented] (FLINK-16493) Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

[ https://issues.apache.org/jira/browse/FLINK-16493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054594#comment-17054594 ] Canbin Zheng commented on FLINK-16493: -- Thanks [~tison] ! > Use enum type instead

[jira] [Created] (FLINK-16493) Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

Canbin Zheng created FLINK-16493: Summary: Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE Key: FLINK-16493 URL: https://issues.apache.org/jira/browse/FLINK-16493

<    1   2   3   4   5   >