Fw: how to reset streaming state regularly

direct or indirect API for this in spark? Or is there any better solution for this? Thanks! shicheng31...@gmail.com

returning type of function that needs to be passed to method 'mapWithState'

= keyValueDStream.mapWithState[StateType, MappedType](spec) Can anyone help me with this problem?Thanks! shicheng31...@gmail.com

Structured Streaming initialized with cached data or others

state'? Or other solutions? Thanks! shicheng31...@gmail.com

ThriftServer gc over exceed and memory problem

v.sh . And the executor's memory does increase. But the problem still exists. What puzzles me is The JDBC Server application serves as driver, only handle some code distribution and rpc connection works.Does it need so much meormy? If so , how to increase it's memory? shicheng31...@gmail.com

Operators supported by Spark Structured Streaming

developing. How did you solve this problem? shicheng31...@gmail.com