Re: Flink 1.18.0 Checkpoints on cancelled jobs

2023-12-14 Thread Ethan T Yang
csHandler > [] - Exception occurred in REST handler: Job > 7504e7a6106093a3a9c7ef35f52ce6cf not found > > > Thanks > Surendra > > > On Sat, Dec 9, 2023 at 12:26 PM Ethan T Yang <mailto:ivanygy...@gmail.com>> wrote: >> Hello Surendra, >> Thank yo

Re: Flink Kubernetes HA

2023-12-06 Thread Ethan T Yang
Never mind. The issue was fix due to the service account permission missing “patch” verb. Which lead to RPC service not started. > On Dec 5, 2023, at 1:40 PM, Ethan T Yang wrote: > > Hi Flink users, > After upgrading Flink ( from 1.13.1 -> 1.18.0), I noticed the an issue when

Re: Flink 1.18.0 jobs in the console keeps changing their orders

2023-12-05 Thread Ethan T Yang
u believe that having a consistent order is a > significant necessity, maybe you can start a discussion in the mailing list > to > improve it. > > Best, > Yuxin > > > Ethan T Yang mailto:ivanygy...@gmail.com>> > 于2023年12月6日周三 06:47写道: >> Hello, >

Flink Kubernetes HA

2023-12-05 Thread Ethan T Yang
Hi Flink users, After upgrading Flink ( from 1.13.1 -> 1.18.0), I noticed the an issue when HA is enabled.( see exception below). I am using k8s deployment and I clean the previous configmaps, like leader files etc. I know the pekko is a recently thing. Can someone share doc on how to use or

Flink 1.18.0 jobs in the console keeps changing their orders

2023-12-05 Thread Ethan T Yang
Hello, I recently upgraded Flink (from 1.13.1 -> 1.18.0). I noticed that the jobs in the Flink console keep changing their order for every refresh. I am wondering if there is a setting to keep them in the chronological order like the 1.13.1. Thanks. Ivan

Flink operator job restart

2023-08-09 Thread Ethan T Yang
Hi Flink users, When using Flink operator, how to restart jobs from a checkpoint. I am used to the Flink Kubernetes native deployment, where I can run flink run -s How to achieve that in Flink operator Thanks Ivan

Flink checkpoint timeout

2023-05-30 Thread Ethan T Yang
Hello all, We recently start to experience Checkpoint timeout randomly. Here are some background information 1. We are on Flink 1.13.1 2. We have been running these type of streaming jobs for years. When checkpoint succeeds, it only take a few seconds. After a week ago, we start to see random