Jungtaek Lim created SPARK-52333: ------------------------------------ Summary: Squeeze protocol for timers (list on specific grouping key, and expiry timers) Key: SPARK-52333 URL: https://issues.apache.org/jira/browse/SPARK-52333 Project: Spark Issue Type: Improvement Components: PySpark, Structured Streaming Affects Versions: 4.1.0 Reporter: Jungtaek Lim
Likewise we did for ListState and MapState, we figured out inlining timers into proto message would give the huge benefit on the state interaction (intercommunication). This ticket aims to address the same change to listing timers for grouping key and expiry timers. -- This message was sent by Atlassian Jira (v8.20.10#820010) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org