As there have been no objections, we are moving forward with this effort. Progress is tracked here: https://issues.apache.org/jira/browse/FLINK-12477 <https://issues.apache.org/jira/browse/FLINK-12477>
Best, Stefan > On 7. May 2019, at 17:39, Stefan Richter <s.rich...@ververica.com> wrote: > > Hi, > > we want to start a discussion about changing the threading-model in stream > task to a mailbox-based approach: > > https://docs.google.com/document/d/1eDpsUKv2FqwZiS1Pm6gYO5eFHScBHfULKmH1-ZEWB4g/edit?usp=sharing > > <https://docs.google.com/document/d/1eDpsUKv2FqwZiS1Pm6gYO5eFHScBHfULKmH1-ZEWB4g/edit?usp=sharing> > > We think that this can greatly improve the usability and maintainability and > also is aligning well with the planned changes from FLIP-27 [1]. Looking > forward to your comments! > > Best, > Stefan > > [1] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface > > <https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface>
