Hi Jungtaek
Thank you very much for clarification
> 5 окт. 2020 г., в 15:17, Jungtaek Lim
> написал(а):
>
>
> Hi,
>
> That's not explained in the SS guide doc but explained in the scala API doc.
> http://spark.apache.org/docs/latest/api/scala/org/apache/spark/sql/streaming/GroupState.html
>
Hi,
That's not explained in the SS guide doc but explained in the scala API doc.
http://spark.apache.org/docs/latest/api/scala/org/apache/spark/sql/streaming/GroupState.html
The statement being quoted from the scala API doc answers your question.
The timeout is reset every time the function is c