Hi all, I would like to start the vote for FLIP-27 which proposes to introduce a new Source connector interface to address a few problems in the existing source connector. The main goals of the the FLIP are following:
1. Unify the Source interface in Flink for batch and stream. 2. Significantly reduce the work for developers to develop new source connectors. 3. Provide a common abstraction for all the sources, as well as a mechanism to allow source subtasks to coordinate among themselves. The vote will last for at least 72 hours, following the consensus voting process. FLIP wiki: https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface Discussion thread: https://lists.apache.org/thread.html/70484d6aa4b8e7121181ed8d5857a94bfb7d5a76334b9c8fcc59700c@%3Cdev.flink.apache.org%3E Thanks, Jiangjie (Becket) Qin