[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] [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] [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-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] [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] [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] [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] [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] [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] [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] [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-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-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] [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-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] [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] [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-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] [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] [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-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] [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] [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] [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] [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] [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] [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] [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=17060691#comment-17060691 ] Canbin Zheng commented on FLINK-15871: -- {color:#0e101a}Hi {color}[{color:#4a6ee0}Ya

[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=17060860#comment-17060860 ] Canbin Zheng commented on FLINK-15871: -- Hi, [~ouyangwuli]! In our internal version

[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] [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] [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] [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] [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] [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-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] [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] [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] [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-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] [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] [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-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] [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-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] [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] [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-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] [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-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] [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] [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] [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-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] [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] [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] [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] [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=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=17066409#comment-17066409 ] Canbin Zheng edited comment on FLINK-16478 at 3/25/20, 6:15 AM: --

<    1   2   3   4   5