Livia Zhu created SPARK-52198:
---------------------------------

             Summary: Fix keySchema in KeyWithIndexToValueStore for join state 
format v3 with column families
                 Key: SPARK-52198
                 URL: https://issues.apache.org/jira/browse/SPARK-52198
             Project: Spark
          Issue Type: Task
          Components: Structured Streaming
    Affects Versions: 4.0.0
            Reporter: Livia Zhu


KeyWithIndexToValueStore adds the wrong schema (keySchema rather than 
keyWithIndexSchema) for the column family for state format v3. This will cause 
an error for operations that use the iterator, including the StateDataSource 
and cleanup operations.



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