[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14004:
-----------------------------
Summary: Define SourceReaderOperator to verify the integration with
StreamOneInputProcessor (was: Define SourceReader interface to verify the
integration with StreamOneInputProcessor)
> Define SourceReaderOperator 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
> Affects Versions: 1.8.0, 1.9.0
> Reporter: zhijiang
> Assignee: zhijiang
> Priority: Minor
> Labels: pull-request-available
> Fix For: 1.10.0
>
> 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)
