Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
StreamExecutionEnvironment currently supports new Source interface based on FLIP-27 in Java, but doesn't support in Python. PyFlink StreamExecutionEnvironment should add methods related to new Source interface like from_source etc.
Attachments
Issue Links
- Blocked
-
FLINK-21971 Support FLIP-27 based kafka source connector in PyFlink DataStream API
- Resolved
- links to