hard20 pts · first answer countskafkaspark-streamingwatermarks
Which window Spark has emitted
A Spark query uses withWatermark("ts", "10 minutes"), 5-minute tumbling windows and append output mode. The highest event time seen so far is 12:20. Which window has been written to the sink?
Discussion 0
Join free to post in the discussion.