Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task SPARK-40581

SPARK-40431 Improving testability of GroupState in applyInPandasWithState

Unassigned Jungtaek Lim Major Open Unresolved  
Sub-task SPARK-40571

SPARK-40431 Construct a test case to verify fault-tolerance semantic with random python worker failures

Jungtaek Lim Jungtaek Lim Major Resolved Fixed  
Sub-task SPARK-40509

SPARK-40431 Construct an example of applyInPandasWithState in examples directory

Chaoqin Li Jungtaek Lim Major Resolved Fixed  
Sub-task SPARK-40444

SPARK-40431 Support initial state in applyInPandasWithState

Unassigned Jungtaek Lim Major Open Unresolved  
Sub-task SPARK-40443

SPARK-40431 Support applyInPandasWithState in batch query

Unassigned Jungtaek Lim Major Open Unresolved  
Sub-task SPARK-40438

SPARK-40431 Support additionalDuration parameter in GroupState.setTimeoutTimestamp

Unassigned Hyukjin Kwon Minor Open Unresolved  
Sub-task SPARK-40437

SPARK-40431 Support string representation of durationMs in GroupState.setTimeoutDuration

Unassigned Hyukjin Kwon Minor Open Unresolved  
Sub-task SPARK-40435

SPARK-40431 Add test suites for applyInPandasWithState in PySpark

Jungtaek Lim Jungtaek Lim Major Resolved Fixed  
Sub-task SPARK-40434

SPARK-40431 Implement applyInPandasWithState in PySpark

Jungtaek Lim Jungtaek Lim Major Resolved Fixed  
Sub-task SPARK-40433

SPARK-40431 Add toJVMRow in PythonSQLUtils to convert pickled PySpark Row to JVM Row

Jungtaek Lim Jungtaek Lim Major Resolved Fixed  
Sub-task SPARK-40432

SPARK-40431 Introduce GroupStateImpl and GroupStateTimeout in PySpark

Jungtaek Lim Jungtaek Lim Major Resolved Fixed  

Cancel