|
|
|
FLINK-22070
|
FLINK-20280
Support FileSink in PyFlink DataStream API
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-22058
|
FLINK-20280
Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21994
|
FLINK-20280
Support FLIP-27 based FileSource connector in PyFlink DataStream API
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21971
|
FLINK-20280
Support FLIP-27 based kafka source connector in PyFlink DataStream API
|
Unassigned
|
Dian Fu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-21953
|
FLINK-20280
Add documentation on batch mode support of Python DataStream API
|
Unassigned
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21939
|
FLINK-20280
Support batch mode in Python DataStream API for process and reduce operation
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21937
|
FLINK-20280
Support batch mode in Python DataStream API for basic operations
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21918
|
FLINK-20280
Add execution.runtime-mode setter in StreamExecutionEnvironment
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21916
|
FLINK-20280
Allow OPERATOR and PYTHON ManagedMemoryUseCase to be used in the same operator
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|