Hi,
I am having issue where after deploying few jobs, it starts failing with below
errors. I don't have such issue in other environments. What should I check
first in such scenario?
My environment is
Azure Kubernetes 1.15.7
Flink 1.6.0
Zookeeper 3.4.10
The program finished with the following exc
Hi,
Does anyone knows what is below error code? Our Flink pod got restarted and we
see below when we do edit pod.
[cid:image001.png@01D5F01E.53D91B40]
Warm Regards,
Samir Chauhan
There's a reason we support Fair Dealing. YOU.
This email and any files transmitted with it or attached to it (t
Hi,
Yesterday morning I got below error in Zookeeper. After this error, my Flink
did not connect to ZK and jobs went to hang state. I had to cancel and redeploy
my all jobs to bring it to normal state.
2020-02-28 02:45:56,811 [myid:1] - WARN
[NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServer
Rohrmann [mailto:trohrm...@apache.org]
Sent: Sunday, October 07, 2018 1:24 AM
To: Samir Tusharbhai Chauhan
Cc: user
Subject: Re: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:
Hi Samir,
1. In your setup (not running on top of Yarn or Mesos) you need to set the
jobmanager.rpc.address
be take care while setting it up?
2. How do I know which job manager is active?
3. How do I secure my cluster?
Samir Chauhan
From: Till Rohrmann [mailto:trohrm...@apache.org]
Sent: Friday, October 05, 2018 11:09 PM
To: Samir Tusharbhai Chauhan
Cc: user
Subject: Re
:58 AM Samir Tusharbhai Chauhan
mailto:samir.tusharbhai.chau...@prudential.com.sg>>
wrote:
[cid:image001.gif@01D45CB1.46C88460]
Hi,
I am having issue in setting up cluster for Flink. I have 2 nodes for Job
Manager and 2 nodes for Task Manager.
My configuration file looks lik
Hi,
I am having issue in setting up cluster for Flink. I have 2 nodes for Job
Manager and 2 nodes for Task Manager.
My configuration file looks like this.
jobmanager.rpc.port: 6123
jobmanager.heap.size: 2048m
taskmanager.heap.size: 2048m
taskmanager.numberOfTaskSlots: 64
parallelism
