[ 
https://issues.apache.org/jira/browse/SPARK-24036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16489700#comment-16489700
 ] 

Arun Mahadevan commented on SPARK-24036:
----------------------------------------

If I understand correctly, continuous job would have a single stage with tasks 
running at the same time shuffling data around (making use of the "TaskInfo" to 
figure out the endpoints). This means we cannot re-use the existing shuffle 
infra since it makes sense only if there are multiple stages ? Does SPARK-24374 
plan to provide the shuffle infra to move data around or is that out of scope ?

> Stateful operators in continuous processing
> -------------------------------------------
>
>                 Key: SPARK-24036
>                 URL: https://issues.apache.org/jira/browse/SPARK-24036
>             Project: Spark
>          Issue Type: Improvement
>          Components: Structured Streaming
>    Affects Versions: 2.4.0
>            Reporter: Jose Torres
>            Priority: Major
>
> The first iteration of continuous processing in Spark 2.3 does not work with 
> stateful operators.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org

Reply via email to