Re: Flink on Minikube

2021-03-26 Thread Robert Metzger
Hey Sandeep, here's a project I've recently worked on, that deploys Flink on Minikube: https://github.com/rmetzger/flink-reactive-mode-k8s-demo The project is pretty big, but I guess you can pick the bits related to the Flink deployment on minikube. On Thu, Mar 25, 2021 at 7:48

Re: Flink on Minikube

2021-03-25 Thread Sandeep khanzode
Hi Arvid, Thanks, will set the scope to Provided and try. Are there public examples in GitHub that demonstrate a sample app in Minikube? Sandeep > On 23-Mar-2021, at 3:17 PM, Arvid Heise wrote: > > Hi Sandeep, > > please have a look at [1], you should add most Flink dependencies as provide

Re: Flink on Minikube

2021-03-23 Thread Arvid Heise
Hi Sandeep, please have a look at [1], you should add most Flink dependencies as provided - exceptions are connectors (or in general stuff that is not in flink/lib/ or flink/plugins). [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/project-configuration.html#setting-up-a-project-ba

Re: Flink on Minikube

2021-03-22 Thread Sandeep khanzode
Hi Arvid, I copy the JAR to the usrlib folder. This works in the Cloud EKS cluster. I wanted to set this up for my testing purposes. Below is the Dockerfile: FROM apache/flink:1.12.1-java11 RUN mv /opt/flink/opt/flink-queryable-state-runtime_2.12-1.12.1.jar /opt/flink/lib/flink-queryable-state-

Re: Flink on Minikube

2021-03-22 Thread Arvid Heise
Hi Sandeep, The first error definitively indicates a classloading issue, which may also be the cause for the second error. Can you describe where you put your jar inside the docker image and which execution mode you are using? As a general rule, the jar is not supposed to go into flink/lib. Also

Flink on Minikube

2021-03-19 Thread Sandeep khanzode
Hello, I have a fat JAR compiled using the Man Shade plugin and everything works correctly when I deploy it on a standalone local cluster i.e. one job and one task manager node. But I installed Minikube and the same JAR file packaged into a docker image fails with weird serialization errors:

Re: Fail to deploy Flink on minikube

2020-09-04 Thread Till Rohrmann
>>> >>>> superainbower >>>> superainbo...@163.com >>>> >>>> <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=superainbower&uid=superainbower%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.12

Re: Fail to deploy Flink on minikube

2020-09-03 Thread superainbower
d you verify that the jobmanager-service has been started? It looks as if the name flink-jobmanager is not resolvable. It could also help to know the Minikube and K8s version you are using. Cheers, Till On Wed, Sep 2, 2020 at 9:50 AM art wrote: Hi,I’m going to deploy flink on minikube refer

Re: Fail to deploy Flink on minikube

2020-09-03 Thread Till Rohrmann
;> >>>> NAME READY STATUSRESTARTS >>>> AGE >>>> pod/flink-jobmanager-85bdbd98d8-ppjmf1/1 Running 0 >>>> 2m34s >>>> pod/flink-taskmanager-74c68c6f48-6jb5v 1/1 Running 0 >>>&

Re: Fail to deploy Flink on minikube

2020-09-02 Thread Yang Wang
gt;>> AGE >>> replicaset.apps/flink-jobmanager-85bdbd98d81 1 1 >>> 2m34s >>> replicaset.apps/flink-taskmanager-74c68c6f48 1 1 1 >>> 2m34s >>> >>> And I can open flink ui but the task man

Re: Fail to deploy Flink on minikube

2020-09-02 Thread superainbower
午4:27,Till Rohrmann 写道: Hi art, could you verify that the jobmanager-service has been started? It looks as if the name flink-jobmanager is not resolvable. It could also help to know the Minikube and K8s version you are using. Cheers, Till On Wed, Sep 2, 2020 at 9:50 AM art wrote: Hi,I

Re: Fail to deploy Flink on minikube

2020-09-02 Thread Yang Wang
bmanager service (K8s >> service) is not running. >> >> Cheers, >> Till >> >> On Wed, Sep 2, 2020 at 11:15 AM art wrote: >> >>> Hi Till, >>> >>> I’m sure the job manager-service is started, I can find it in Kubernetes >>&

Re: Fail to deploy Flink on minikube

2020-09-02 Thread superainbower
that the jobmanager-service has been started? It looks as if the name flink-jobmanager is not resolvable. It could also help to know the Minikube and K8s version you are using. Cheers, Till On Wed, Sep 2, 2020 at 9:50 AM art wrote: Hi,I’m going to deploy flink on minikube referring to https:/

Re: Fail to deploy Flink on minikube

2020-09-02 Thread superainbower
know the Minikube and K8s version you are using. Cheers, Till On Wed, Sep 2, 2020 at 9:50 AM art wrote: Hi,I’m going to deploy flink on minikube referring to https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/ops/deployment/kubernetes.html; kubectl create -f flink-configurati

Re: Fail to deploy Flink on minikube

2020-09-02 Thread Till Rohrmann
i art, >> >> could you verify that the jobmanager-service has been started? It looks >> as if the name flink-jobmanager is not resolvable. It could also help to >> know the Minikube and K8s version you are using. >> >> Cheers, >> Till >> &

Re: Fail to deploy Flink on minikube

2020-09-02 Thread art
>> >> could you verify that the jobmanager-service has been started? It looks as >> if the name flink-jobmanager is not resolvable. It could also help to know >> the Minikube and K8s version you are using. >> >> Cheers, >> Till >> >&g

Re: Fail to deploy Flink on minikube

2020-09-02 Thread Till Rohrmann
写道: > > Hi art, > > could you verify that the jobmanager-service has been started? It looks as > if the name flink-jobmanager is not resolvable. It could also help to know > the Minikube and K8s version you are using. > > Cheers, > Till > > On Wed, Sep 2, 2020

Re: Fail to deploy Flink on minikube

2020-09-02 Thread Till Rohrmann
Hi art, could you verify that the jobmanager-service has been started? It looks as if the name flink-jobmanager is not resolvable. It could also help to know the Minikube and K8s version you are using. Cheers, Till On Wed, Sep 2, 2020 at 9:50 AM art wrote: > Hi,I’m going to deploy flink

Fail to deploy Flink on minikube

2020-09-02 Thread art
Hi,I’m going to deploy flink on minikube referring to https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/ops/deployment/kubernetes.html <https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/ops/deployment/kubernetes.html>; kubectl create -f flink-configu