[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14004:
-----------------------------
Description: 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. (was: 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.)
> 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 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
