Flink kafka producer using the same transactional id twice?

2022-09-05 Thread Sebastian Struss
Hi all, i am quite new to flink and kafka, so i might mix something up here. The situation is that we do have a flink application (1.14.5 with scala 2.12) running for a few hours to days and suddenly it stops working and can't publish to kafka anymore. I then noticed this message showing up twice

Re: Flink Web ui not stable in kubernetes?

2022-03-25 Thread Sebastian Struss
Vauvert < guillaume.vauvert@gmail.com> wrote: > Hello Sebastian, > > Multiple versions of Flink 1.14.x are known to have issue with UI/CLI, > please switch to Flink 1.14.4. > > Best regards, > > Guillaume > On 25/03/2022 08.42, Sebastian Struss wrote: > &

Flink Web ui not stable in kubernetes?

2022-03-25 Thread Sebastian Struss
Hello all, i've been setting up flink in my kubernetes cluster with 2 job managers and 1 task manager (custom helm chart i wrote, no flink CLI used). I can access the web ui, but often it seems to switch pods which i am connected to and as soon as i am connected to the standby job manager it doesn