Hi Yang,
Thanks for the reply, those information is very helpful.
Best,
Fuyao
From: Yang Wang
Date: Tuesday, April 6, 2021 at 01:11
To: Fuyao Li
Cc: user
Subject: Re: [External] : Re: Need help with executing Flink CLI for native
Kubernetes deployment
Hi Fuyao,
Sorry for the late reply
help of ZooKeeper. In terms
> of this, native k8s is better. Any other ideas? Thanks for your help.
>
>
>
> Best,
>
> Fuyao
>
>
>
> *From: *Fuyao Li
> *Date: *Thursday, April 1, 2021 at 12:22
> *To: *Yang Wang
> *Cc: *user
> *Subject: *Re: [External] : R
for your help.
Best,
Fuyao
From: Fuyao Li
Date: Thursday, April 1, 2021 at 12:22
To: Yang Wang
Cc: user
Subject: Re: [External] : Re: Need help with executing Flink CLI for native
Kubernetes deployment
Hi Yang,
Thanks for sharing the insights.
For problem 1:
I think I can’t do telnet in the
://github.com/GoogleCloudPlatform/flink-on-k8s-operator
[2] https://github.com/lyft/flinkk8soperator
[3] https://youtu.be/pdFPr_VOWTU
Best,
Fuyao
From: Yang Wang
Date: Tuesday, March 30, 2021 at 19:15
To: Fuyao Li
Cc: user
Subject: Re: [External] : Re: Need help with executing Flink CLI for native
network configuration, but failed to find a reason, could you give me some
>hints?
>3. In production, what is the suggested approach to list and cancel
>jobs? The current manual work of “kubectl exec” into pods is not very
>reliable.. How to automate this process
thanks.
Best,
Fuyao
From: Yang Wang
Date: Monday, March 29, 2021 at 20:40
To: Fuyao Li
Cc: user
Subject: [External] : Re: Need help with executing Flink CLI for native
Kubernetes deployment
Hi Fuyao,
Thanks for trying the native Kubernetes integration.
Just like you know, the Flink rest serv
Hi Fuyao,
Thanks for trying the native Kubernetes integration.
Just like you know, the Flink rest service could be exposed in following
three types, configured via "kubernetes.rest-service.exposed.type".
* ClusterIP, which means you could only access the Flink rest endpoint
inside the K8s cluste
Hi Community, Yang,
I am new to Flink on native Kubernetes and I am trying to do a POC for native
Kubernetes application mode on Oracle Cloud Infrastructure. I was following the
documentation here step by step: [1]
I am using Flink 1.12.1, Scala 2.11, java 11.
I was able to create a native Kube
