apache

/

flink

branch iconmaster

arrow to build time
clock icon2 hrs, 29 mins, 16 secs

Zhijiang avatarZhijiang

[FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor

We already refactored the task input and output in runtime stack for considering the requirements of FLIP-27. In order to
further verify that the new source could work well with the unified StreamOneInputProcessor in mailbox model, we define the
SourceReaderOperator as task input and implement a unit test for passing through the whole process.

Reply via email to