Re: Re:Re: Re:Re: Event stuck in the Flink operator

2023-12-19 Thread T, Yadhunath
Hi Xuyang, Thanks for the reply! I haven't used a print connector yet. Thanks, Yad From: Xuyang Sent: Monday, December 18, 2023 8:26 AM To: T, Yadhunath Cc: user@flink.apache.org Subject: Re:Re: Re:Re: Event stuck in the Flink operator This Message Is

Re: Re:Re: Event stuck in the Flink operator

2023-12-15 Thread T, Yadhunath
f you need to react to the non-arrival of data. Just make sure you cancel it when data finally does arrive. :) -0xe1a On Thu, Dec 14, 2023 at 6:36 AM T, Yadhunath mailto:yadhunat...@boarshead.com>> wrote: Hi, I am using Flink version 1.16 and I have a streaming job that uses PyFlin

Re: Event stuck in the Flink operator

2023-12-15 Thread T, Yadhunath
AM To: T, Yadhunath Cc: user@flink.apache.org ; Shames, Joy ; Maj, Marek ; Kornegay, Robert ; Michael, Dennis ; Kerelli, Sharath Subject: Re: Event stuck in the Flink operator Can you share your precise join semantics? I don't know about Flink SQL offhand, but here are a couple ways

Event stuck in the Flink operator

2023-12-14 Thread T, Yadhunath
Hi, I am using Flink version 1.16 and I have a streaming job that uses PyFlinkSQL API. Whenever a new streaming event comes in it is not getting processed in the last Flink operator ( it performs temporal join along with writing data into Kafka topic) and it will be only pushed to Kafka on th