You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@spark.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/28 05:14:00 UTC

[jira] [Updated] (SPARK-52333) Squeeze protocol for timers (list on specific grouping key, and expiry timers)

     [ https://issues.apache.org/jira/browse/SPARK-52333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

ASF GitHub Bot updated SPARK-52333:
-----------------------------------
    Labels: pull-request-available  (was: )

> 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
>            Priority: Major
>              Labels: pull-request-available
>
> 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-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org