Re: Check points are discarded with reason NULL

Hi, This exception is thrown because the number of checkpoint exceptions exceeds execution.checkpointing.tolerable-failed-checkpoints, see [1] for more details. There should be other root causes about the checkpoint exception in your JM/TM logs. You could check or share these. [1] https://nightlie

Re: kafka sink

Hi nick, Is there any error log? That may help to analyze the root cause. On Sun, Jul 23, 2023 at 9:53 PM nick toker wrote: > hello > > > we replaced deprecated kafka producer with kafka sink > and from time to time when we submit a job he stack for 5 min in > inisazaing ( on sink operators) >

Re: Set processing time in the past

Hi, Eugenio Can you describe the requirements in more detail? Best, Ron Shammon FY 于2023年7月17日周一 09:10写道： > Hi Eugenio, > > I cannot catch it clearly, could you describe it in more detail? > > Best, > Shammon FY > > On Sat, Jul 15, 2023 at 5:14 PM Eugenio Marotti < > ing.eugenio.maro...@gmail.

RE: TCP server socket with Kubernetes Cluster

Hello Community, Please share views for below mail. Rgds, Kamal From: Kamal Mittal via user Sent: 21 July 2023 02:02 PM To: user@flink.apache.org Subject: TCP server socket with Kubernetes Cluster Hello, Created a TCP server socket single source function and it is opened on a single POD (ta

kafka sink

hello we replaced deprecated kafka producer with kafka sink and from time to time when we submit a job he stack for 5 min in inisazaing ( on sink operators) we verify the the transaction prefix is unique it's not happened when we use kafka producer What can be the reason?