[
https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883666#comment-16883666
]
Wenlong Lyu commented on FLINK-10740:
-------------------------------------
Hi, all, there may be one important feature missed in the discuss before: How
do we handle the changes of SourceSplit during the lifecycle of a job since It
is common for a mesage queue to increase or decrease shards dynamically. I
think it is necessary to be supported in the new source interface.
> Refactor Source Interface
> -------------------------
>
> Key: FLINK-10740
> URL: https://issues.apache.org/jira/browse/FLINK-10740
> Project: Flink
> Issue Type: Improvement
> Components: API / DataSet, API / DataStream
> Reporter: Aljoscha Krettek
> Priority: Major
>
> Please see the FLIP for any details:
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
