[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang resolved FLINK-14004.
------------------------------
Resolution: Fixed
Merged in master: cee9bf0ab6c1d6b1678070ff2e05f0aa34f26dc0
> Define SourceReader interface to verify the integration with
> StreamOneInputProcessor
> ------------------------------------------------------------------------------------
>
> Key: FLINK-14004
> URL: https://issues.apache.org/jira/browse/FLINK-14004
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Task
> Reporter: zhijiang
> Assignee: zhijiang
> Priority: Minor
> Labels: pull-request-available
> Time Spent: 20m
> Remaining Estimate: 0h
>
> We already refactored the task input and output sides based on the new source
> characters in FLIP-27. In order to further verify that the new source reader
> could work well with the unified StreamOneInputProcessor in mailbox model, we
> would design a unit test for integrating the whole process. In detail:
> * Define SourceReader and SourceOutput relevant interfaces based on FLIP-27
> * Implement an example of stateless SourceReader (bounded sequence of
> integers)
> * Define SourceReaderOperator to integrate the SourceReader with
> StreamOneInputProcessor
> * Define SourceReaderStreamTask to execute the source input and implement a
> unit test for it.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
