|
|
|
SPARK-23845
|
SPARK-22911
Continuous rate source uses different offset format
|
Unassigned
|
Saisai Shao
|
|
Resolved |
Incomplete
|
|
|
|
|
|
|
|
SPARK-23561
|
SPARK-22911
make StreamWriter not a DataSourceWriter subclass
|
Unassigned
|
Jose Torres
|
|
Resolved |
Incomplete
|
|
|
|
|
|
|
|
SPARK-23559
|
SPARK-22911
add epoch ID to data writer factory
|
Jose Torres
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23558
|
SPARK-22911
clean up StreamWriter factory lifecycle
|
Unassigned
|
Jose Torres
|
|
Resolved |
Incomplete
|
|
|
|
|
|
|
|
SPARK-23557
|
SPARK-22911
design doc for read side
|
Unassigned
|
Jose Torres
|
|
Resolved |
Done
|
|
|
|
|
|
|
|
SPARK-23556
|
SPARK-22911
design doc for write side
|
Unassigned
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23362
|
SPARK-22911
Migrate Kafka microbatch source to v2
|
Tathagata Das
|
Tathagata Das
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23196
|
SPARK-22911
Unify continuous and microbatch V2 sinks
|
Jose Torres
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23102
|
SPARK-22911
Migrate kafka sink
|
Unassigned
|
Jose Torres
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
SPARK-23101
|
SPARK-22911
Migrate unit test sinks
|
Unassigned
|
Jose Torres
|
|
Resolved |
Incomplete
|
|
|
|
|
|
|
|
SPARK-23100
|
SPARK-22911
Migrate unit test sources
|
Unassigned
|
Jose Torres
|
|
Resolved |
Incomplete
|
|
|
|
|
|
|
|
SPARK-23099
|
SPARK-22911
Migrate foreach sink
|
Jose Torres
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23098
|
SPARK-22911
Migrate Kafka batch source to v2
|
Gabor Somogyi
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23097
|
SPARK-22911
Migrate text socket source to v2
|
Saisai Shao
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23096
|
SPARK-22911
Migrate rate source to v2
|
Saisai Shao
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23052
|
SPARK-22911
Migrate Microbatch ConsoleSink to v2
|
Jose Torres
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23014
|
SPARK-22911
Migrate MemorySink fully to v2
|
Gabor Somogyi
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-23013
|
SPARK-22911
Migrate MemoryStream to V2
|
Unassigned
|
Jose Torres
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
SPARK-22912
|
SPARK-22911
Support v2 streaming sources and sinks in MicroBatchExecution
|
Unassigned
|
Jose Torres
|
|
Resolved |
Fixed
|
|
|
|
|