[
https://issues.apache.org/jira/browse/FLINK-11875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940925#comment-16940925
]
Piotr Nowojski commented on FLINK-11875:
----------------------------------------
I moved benchmark instability as a separate issue and closed this ticket.
> Enhance stream operator API to support selective reading and EndOfInput event
> -----------------------------------------------------------------------------
>
> Key: FLINK-11875
> URL: https://issues.apache.org/jira/browse/FLINK-11875
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Task
> Reporter: Haibo Sun
> Assignee: Haibo Sun
> Priority: Major
> Fix For: 1.9.0
>
>
> Towards the goal that unify Streaming and Batch, this jira proposes enhanced
> stream operator api to support selective reading and EndOfInput event for
> currently Batch’s requirements.
> [Design
> Doc|https://docs.google.com/document/d/10k5pQm3SkMiK5Zn1iFDqhQnzjQTLF0Vtcbc8poB4_c8/edit?usp=sharing]
> [Discussion
> Mail|http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Enhance-Operator-API-to-Support-Dynamically-Selective-Reading-and-EndOfInput-Event-td26753.html]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
