Unsubscribe
--
С уважением,
Павел Гладков
Hi,
I have the same use-case, can you please let me know the implementation for
the same.
--
Sent from: http://apache-spark-developers-list.1001551.n3.nabble.com/
-
To unsubscribe e-mail: dev-unsubscr...@spark.apache.org
Hi,
I think I know where the issue surfaces. This is with groupBy
aggregation with Append output mode.
What should happen when a state expires for a event time (in groupBy)
with the new rows for the expired key in a streaming batch exactly
when watermark has been moved up and thus expired the
