Re: File Source Watermark Issue
Hi Kirti Dhar, There isn't really enough information to answer it: are you using Flink in bounded mode, how have you created your job, what is appearing in the logs etc. Best regards, Martijn On Mon, Oct 16, 2023 at 7:01 AM Kirti Dhar Upadhyay K via user wrote: > > Hi Community, > > > > Can someone help me here? > > > > Regards, > > Kirti Dhar > > > > From: Kirti Dhar Upadhyay K > Sent: 10 October 2023 15:52 > To: user@flink.apache.org > Subject: File Source Watermark Issue > > > > Hi Team, > > > > I am using Flink File Source with window aggregator as process function, and > stuck with a weird issues. > > File source doesn’t seem emitting/progressing the watermarks, whereas if I > put a delay (say 100ms) while extracting timestamp from event, it is working > fine. > > > > A bit same thing I found in comments here > https://stackoverflow.com/questions/68736330/flink-watermark-not-advancing-at-all-stuck-at-9223372036854775808/68743019#68743019 > > > > Can someone help me here? > > > > Regards, > > Kirti Dhar
RE: File Source Watermark Issue
Hi Community, Can someone help me here? Regards, Kirti Dhar From: Kirti Dhar Upadhyay K Sent: 10 October 2023 15:52 To: user@flink.apache.org Subject: File Source Watermark Issue Hi Team, I am using Flink File Source with window aggregator as process function, and stuck with a weird issues. File source doesn't seem emitting/progressing the watermarks, whereas if I put a delay (say 100ms) while extracting timestamp from event, it is working fine. A bit same thing I found in comments here https://stackoverflow.com/questions/68736330/flink-watermark-not-advancing-at-all-stuck-at-9223372036854775808/68743019#68743019 Can someone help me here? Regards, Kirti Dhar
File Source Watermark Issue
Hi Team, I am using Flink File Source with window aggregator as process function, and stuck with a weird issues. File source doesn't seem emitting/progressing the watermarks, whereas if I put a delay (say 100ms) while extracting timestamp from event, it is working fine. A bit same thing I found in comments here https://stackoverflow.com/questions/68736330/flink-watermark-not-advancing-at-all-stuck-at-9223372036854775808/68743019#68743019 Can someone help me here? Regards, Kirti Dhar
