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

Posted to issues@spark.apache.org by "Neil Ramaswamy (Jira)" <ji...@apache.org> on 2024/08/06 21:59:00 UTC

[jira] [Created] (SPARK-49131) TransformWithState doesn't set implicit grouping key when lazy iterators are used

Neil Ramaswamy created SPARK-49131:
--------------------------------------

             Summary: TransformWithState doesn't set implicit grouping key when lazy iterators are used
                 Key: SPARK-49131
                 URL: https://issues.apache.org/jira/browse/SPARK-49131
             Project: Spark
          Issue Type: Improvement
          Components: Structured Streaming
    Affects Versions: 4.0.0
            Reporter: Neil Ramaswamy


When a lazy iterator is used, the implicit key for state updates in TWS is not set properly. This is because the implicit key is set as a thread local only when `handleInputRows` is called, not when methods on the returned iterator are invoked. Both eager and lazy iterators should be supported.



--
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