|
apache
/
flink
|
|
master
|
2 hrs, 29 mins, 16 secs
|
Zhijiang
|
|
[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.
|
|