Siying Dong created SPARK-51682:
-----------------------------------

             Summary: State Store Checkpoint V2 should handle offset log ahead 
of commit log correctly
                 Key: SPARK-51682
                 URL: https://issues.apache.org/jira/browse/SPARK-51682
             Project: Spark
          Issue Type: Task
          Components: Structured Streaming
    Affects Versions: 4.0.0
            Reporter: Siying Dong


Right now, there is a bug of reading checkpoint ID from commit log when the 
query restarts. If the offset log is ahead of commit log, it doesn't read it, 
and the tasks won't hve checkpoint ID to recover from.



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

Reply via email to