ieve faster failover.
6. Support to configure limit for CPU requirement
Description:
To leverage the Kubernetes feature of container request/limit CPU.
Benefits:
Reduce cost.
Regards,
Canbin Zheng
Harold.Miao 于2020年7月23日周四 下午12:44写道：
> I'm excited to hear about this feature
+1 (non-binding)
Regards,
Canbin Zheng
Till Rohrmann 于2020年5月18日周一 下午4:40写道：
> +1 (binding)
>
> On Mon, May 18, 2020 at 6:02 AM Tzu-Li (Gordon) Tai
> wrote:
>
> > +1
> >
> > On Mon, May 18, 2020 at 11:47 AM Xintong Song
> > wrote:
> >
Canbin Zheng created FLINK-17709:
Summary: Active Kubernetes integration phase 3 - Advanced Features
Key: FLINK-17709
URL: https://issues.apache.org/jira/browse/FLINK-17709
Project: Flink
Canbin Zheng created FLINK-17707:
Summary: Support configuring replica of Deployment in ZooKeeper
based HA setups
Key: FLINK-17707
URL: https://issues.apache.org/jira/browse/FLINK-17707
Project
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
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
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
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
That sounds like a good refactoring for consistency, +1 from my side
Regards,
Canbin Zheng
zoudan 于2020年5月6日周三 上午9:44写道：
> +1 from my side, it will make jdbc connector unified with other ones.
>
> Best,
> Dan Zou
>
>
> > 在 2020年4月30日，23:16，Jark Wu 写道：
> >
> &
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
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
Canbin Zheng created FLINK-17273:
Summary: Fix not calling
ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case
of registered TaskExecutor failure
Key: FLINK-17273
URL: https
Congratulations Hequn!
Regards,
Canbin Zheng
wenlong.lwl 于2020年4月20日周一 下午8:02写道：
> Congratulations Hequn!
>
> Bests,
> Wenlong
>
> On Mon, 20 Apr 2020 at 17:56, Yuan Mei wrote:
>
> > Congrats!
> >
> > On Fri, Apr 17, 2020 at 2:44 PM Becket Qin wrote:
Canbin Zheng created FLINK-17232:
Summary: Rethink the implicit behavior to use the Service
externalIP as the address of the Endpoint
Key: FLINK-17232
URL: https://issues.apache.org/jira/browse/FLINK-17232
Canbin Zheng created FLINK-17231:
Summary: Deprecate possible implicit fallback from LB to NodePort
When retrieving Endpoint of LB Service
Key: FLINK-17231
URL: https://issues.apache.org/jira/browse/FLINK-17231
Canbin Zheng created FLINK-17230:
Summary: Fix incorrect returned address of Endpoint for the
ClusterIP Service
Key: FLINK-17230
URL: https://issues.apache.org/jira/browse/FLINK-17230
Project: Flink
Canbin Zheng created FLINK-17196:
Summary: Rework the implementation of
Fabric8FlinkKubeClient#getRestEndpoint
Key: FLINK-17196
URL: https://issues.apache.org/jira/browse/FLINK-17196
Project: Flink
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
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
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
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
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
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
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:
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
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
cket‘s description.
2. FLINK-17034 <https://issues.apache.org/jira/browse/FLINK-17034> for
suggesting executing the container CMD under TINI.
Regards,
Canbin Zheng
Andrey Zagrebin 于2020年4月7日周二 下午4:58写道：
> Hi all,
>
> Thanks for the further feedback Niels and Canbin.
>
> @Niels
>
>
Thanks for the FLIP Andrey.
+1 (non-binding) from my side.
Regards,
Canbin Zheng
Yang Wang 于2020年4月8日周三 上午9:57写道：
> Thanks Andrey for the efforts of docker image unification.
>
> +1 (non-binding)
>
> Best,
> Yang
>
> Till Rohrmann 于2020年4月7日周二 下午11:04写道：
>
> &g
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
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
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
/engine/reference/commandline/kill/
[4]
https://issues.apache.org/jira/browse/FLINK-15843
Regards,
Canbin Zheng
Till Rohrmann 于2020年4月6日周一 下午5:34写道：
> Thanks for the feedback Niels. This is very helpful.
>
> 1. I agree `flink:latest` is nice to get started but in the long run people
&g
Canbin Zheng created FLINK-17008:
Summary: Handle null value for HADOOP_CONF_DIR/HADOOP_HOME env in
AbstractKubernetesParameters#getLocalHadoopConfigurationDirectory
Key: FLINK-17008
URL: https
to fix it.
>
> Cheers,
> Till
>
> On Wed, Apr 1, 2020 at 11:26 AM Canbin Zheng
> wrote:
>
>> Hi everyone,
>>
>> Recently I failed to run a Flink job when enabling RocksDBStateBackend on
>>
Congratulations to all of you!
Regards,
Canbin Zheng.
tison 于2020年4月1日周三 下午7:00写道：
> Congratulations to all of you. Well deserved.
>
> Best,
> tison.
>
>
> Yingjie Cao 于2020年4月1日周三 下午6:31写道：
>
> > Congratulations!
> >
> > Best,
> > Yin
Thanks Yangze for driving the initial CPU support!
+1 (non-binding) from my side.
Xintong Song 于2020年4月1日周三 下午6:36写道：
> Thanks Yangze, the FLIP looks good to me.
> +1 (non-binding) from my side.
>
> Thank you~
>
> Xintong Song
>
>
>
> On Wed, Apr 1, 2020 at 5:22 PM Yangze Guo wrote:
>
> > Hi e
UnsupportedOperationException that causes problems.
Regards,
Canbin Zheng
Canbin Zheng created FLINK-16913:
Summary: ReadableConfigToConfigurationAdapter#getEnum throws
UnsupportedOperationException
Key: FLINK-16913
URL: https://issues.apache.org/jira/browse/FLINK-16913
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Thanks very much Yang Wang.
Cheers,
Canbin Zheng
Yang Wang 于2020年2月27日周四 下午9:19写道：
> Great work! I could help to review and test.
>
> Best,
> Yang
>
> Canbin Zheng 于2020年2月27日周四 下午4:24写道：
>
>> Hi, everyone,
>>
>> I have pushed a PR <https://gi
Hi, everyone,
I have pushed a PR <https://github.com/apache/flink/pull/11233> for this
issue, looking forward to your feedback.
Cheers,
Canbin Zheng
Canbin Zheng 于2020年2月26日周三 上午10:39写道：
> Thanks for the detailed PR advice, I would separate the commits as clear
> as possible to h
Thanks for the detailed PR advice, I would separate the commits as clear as
possible to help the code reviewing.
Cheers,
Canbin Zheng
tison 于2020年2月25日周二 下午10:11写道：
> Thanks for your clarification Yang! We're on the same page.
>
> Best,
> tison.
>
>
> Yang Wan
Hi, Till,
Great thanks for your advice, I totally agree with you to split the changes
up in as many PRs as possible. The part of "Parameter Parser" is trivial so
that we prefer to make one PR to avoid adapting a lot of pieces of code
that would be deleted immediately with the following decorator r
n.
>
>
> Yang Wang 于2020年2月24日周一 下午8:38写道：
>
>> It seems that we could benefit a lot from the "Parameters Parser". Let's
>> start to
>> add the dedicated jobmanager/taskmanager config parser classes.
>>
>>
>> Best,
>&g
Congratulations !!
Dawid Wysakowicz 于2020年2月24日周一 下午3:55写道：
> Congratulations Jingsong!
>
> Best,
>
> Dawid
>
> On 24/02/2020 08:12, zhenya Sun wrote:
> > Congratulations！！！
> > | |
> > zhenya Sun
> > |
> > |
> > toke...@126.com
> > |
> > 签名由网易邮箱大师定制
> >
> >
> > On 02/24/2020 14:35，Yu Li wrote：
Canbin Zheng created FLINK-16253:
Summary: Switch to Log4j 2 by default for flink-kubernetes
submodule
Key: FLINK-16253
URL: https://issues.apache.org/jira/browse/FLINK-16253
Project: Flink
ial in some scenarios
since we can avoid useless effort on Kubernetes resource creation in case
of failures leading to clean up all the created resources.
Regards,
Canbin Zheng
Yang Wang 于2020年2月23日周日 下午10:37写道：
> > The new introduced decorator
> After some offline discussion with Canbin
Canbin Zheng created FLINK-16240:
Summary: Port KubernetesUtilsTest to the right package
Key: FLINK-16240
URL: https://issues.apache.org/jira/browse/FLINK-16240
Project: Flink
Issue Type
Canbin Zheng created FLINK-16239:
Summary: Port KubernetesSessionCliTest to the right package
Key: FLINK-16239
URL: https://issues.apache.org/jira/browse/FLINK-16239
Project: Flink
Issue
Canbin Zheng created FLINK-16238:
Summary: Rename class name of Fabric8ClientTest to
Fabric8FlinkKubeClient
Key: FLINK-16238
URL: https://issues.apache.org/jira/browse/FLINK-16238
Project: Flink
Canbin Zheng created FLINK-16194:
Summary: Refactor the Kubernetes resouces construction architecture
Key: FLINK-16194
URL: https://issues.apache.org/jira/browse/FLINK-16194
Project: Flink
Canbin Zheng created FLINK-16025:
Summary: Service could expose different blob server port
mismatched with JM Container
Key: FLINK-16025
URL: https://issues.apache.org/jira/browse/FLINK-16025
Project
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
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
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
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
Canbin Zheng created FLINK-15822:
Summary: Rethink the necessity of the internal Service
Key: FLINK-15822
URL: https://issues.apache.org/jira/browse/FLINK-15822
Project: Flink
Issue Type
Canbin Zheng created FLINK-15817:
Summary: Kubernetes Resource leak while deployment exception
happens
Key: FLINK-15817
URL: https://issues.apache.org/jira/browse/FLINK-15817
Project: Flink
Canbin Zheng created FLINK-15816:
Summary: Limit the maximum length of the value of
kubernetes.cluster-id configuration option
Key: FLINK-15816
URL: https://issues.apache.org/jira/browse/FLINK-15816
Canbin Zheng created FLINK-15667:
Summary: Hadoop Configurations Mount Support
Key: FLINK-15667
URL: https://issues.apache.org/jira/browse/FLINK-15667
Project: Flink
Issue Type: New Feature
Canbin Zheng created FLINK-15666:
Summary: GPU scheduling support in Kubernetes mode
Key: FLINK-15666
URL: https://issues.apache.org/jira/browse/FLINK-15666
Project: Flink
Issue Type: New
Canbin Zheng created FLINK-15665:
Summary: External shuffle service support in Kubernetes mode
Key: FLINK-15665
URL: https://issues.apache.org/jira/browse/FLINK-15665
Project: Flink
Issue
Canbin Zheng created FLINK-15663:
Summary: Kerberos Support in Kubernetes Deploy Mode
Key: FLINK-15663
URL: https://issues.apache.org/jira/browse/FLINK-15663
Project: Flink
Issue Type: New
Canbin Zheng created FLINK-15662:
Summary: Make K8s client timeouts configurable
Key: FLINK-15662
URL: https://issues.apache.org/jira/browse/FLINK-15662
Project: Flink
Issue Type
Canbin Zheng created FLINK-15659:
Summary: Introduce a client-side StatusWatcher for JM Pods
Key: FLINK-15659
URL: https://issues.apache.org/jira/browse/FLINK-15659
Project: Flink
Issue Type
Canbin Zheng created FLINK-15656:
Summary: Support user-specified pod templates
Key: FLINK-15656
URL: https://issues.apache.org/jira/browse/FLINK-15656
Project: Flink
Issue Type: New Feature
Canbin Zheng created FLINK-15654:
Summary: Expose podIP for Containers by Environment Variables
Key: FLINK-15654
URL: https://issues.apache.org/jira/browse/FLINK-15654
Project: Flink
Issue
Canbin Zheng created FLINK-15653:
Summary: Support to configure request or limit for MEM requirement
Key: FLINK-15653
URL: https://issues.apache.org/jira/browse/FLINK-15653
Project: Flink
Canbin Zheng created FLINK-15652:
Summary: Support for imagePullSecrets k8s option
Key: FLINK-15652
URL: https://issues.apache.org/jira/browse/FLINK-15652
Project: Flink
Issue Type: New
Canbin Zheng created FLINK-15649:
Summary: Support mounting volumes
Key: FLINK-15649
URL: https://issues.apache.org/jira/browse/FLINK-15649
Project: Flink
Issue Type: New Feature
Canbin Zheng created FLINK-15648:
Summary: Support to configure request or limit for CPU requirement
Key: FLINK-15648
URL: https://issues.apache.org/jira/browse/FLINK-15648
Project: Flink
Canbin Zheng created FLINK-15647:
Summary: Support to set annotations for JM/TM Pods
Key: FLINK-15647
URL: https://issues.apache.org/jira/browse/FLINK-15647
Project: Flink
Issue Type: New
Canbin Zheng created FLINK-15646:
Summary: Configurable K8s context support
Key: FLINK-15646
URL: https://issues.apache.org/jira/browse/FLINK-15646
Project: Flink
Issue Type: New Feature
Canbin Zheng created FLINK-14432:
Summary: Add 'SHOW SYSTEM FUNCTIONS' support in SQL CLI
Key: FLINK-14432
URL: https://issues.apache.org/jira/browse/FLINK-14432
Project: Flink
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
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
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
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
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
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
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
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
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
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
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
100 matches
Mail list logo
