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