Re: Spark structural streaming sinks output late

2020-03-28 Thread Siva Samraj
Yes, I am also facing the same issue. Did you figured out? On Tue, 9 Jul 2019, 7:25 pm Kamalanathan Venkatesan, < kamalanatha...@in.ey.com> wrote: > Hello, > > > > I have below spark structural streaming code and I was expecting the > results to be printed on the console every 10 seconds. But, I

Re: Spark structural streaming sinks output late

2019-07-10 Thread Magnus Nilsson
Well, you should get updates every 10 seconds as long as there are events surviving your quite aggressive watermark condition. Spark will try to drop (not guaranteed) all events with a timestamp more than 500 milliseconds before the current watermark timestamp. Try to increase the watermark timespa

RE: Spark structural streaming sinks output late

2019-07-10 Thread Kamalanathan Venkatesan
Hello, Any observations on what am I doing wrong? Thanks, -Kamal From: Kamalanathan Venkatesan Sent: Tuesday, July 09, 2019 7:25 PM To: 'user@spark.apache.org' Subject: Spark structural streaming sinks output late Hello, I have below spark structural streaming code and I was expecting the res