|
|
|
SPARK-40581
|
SPARK-40431
Improving testability of GroupState in applyInPandasWithState
|
Unassigned
|
Jungtaek Lim
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
SPARK-40571
|
SPARK-40431
Construct a test case to verify fault-tolerance semantic with random python worker failures
|
Jungtaek Lim
|
Jungtaek Lim
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40509
|
SPARK-40431
Construct an example of applyInPandasWithState in examples directory
|
Chaoqin Li
|
Jungtaek Lim
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40444
|
SPARK-40431
Support initial state in applyInPandasWithState
|
Unassigned
|
Jungtaek Lim
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
SPARK-40443
|
SPARK-40431
Support applyInPandasWithState in batch query
|
Unassigned
|
Jungtaek Lim
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
SPARK-40438
|
SPARK-40431
Support additionalDuration parameter in GroupState.setTimeoutTimestamp
|
Unassigned
|
Hyukjin Kwon
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
SPARK-40437
|
SPARK-40431
Support string representation of durationMs in GroupState.setTimeoutDuration
|
Unassigned
|
Hyukjin Kwon
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
SPARK-40435
|
SPARK-40431
Add test suites for applyInPandasWithState in PySpark
|
Jungtaek Lim
|
Jungtaek Lim
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40434
|
SPARK-40431
Implement applyInPandasWithState in PySpark
|
Jungtaek Lim
|
Jungtaek Lim
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40433
|
SPARK-40431
Add toJVMRow in PythonSQLUtils to convert pickled PySpark Row to JVM Row
|
Jungtaek Lim
|
Jungtaek Lim
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40432
|
SPARK-40431
Introduce GroupStateImpl and GroupStateTimeout in PySpark
|
Jungtaek Lim
|
Jungtaek Lim
|
|
Resolved |
Fixed
|
|
|
|
|