[ 
https://issues.apache.org/jira/browse/FLINK-23633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534465#comment-17534465
 ] 

Xinbin Huang commented on FLINK-23633:
--------------------------------------

[~thw] it would be great to assign the issue to me. I have a rough idea on how 
to approach this. Maybe I can put it down here the next a few days and we can 
chat about it first?

> HybridSource: Support dynamic stop position in FileSource
> ---------------------------------------------------------
>
>                 Key: FLINK-23633
>                 URL: https://issues.apache.org/jira/browse/FLINK-23633
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / FileSystem
>            Reporter: Thomas Weise
>            Priority: Major
>
> As of FLINK-22670 FileSource can be used with HybridSource with fixed end 
> position. To support the scenario where the switch position isn't known ahead 
> of time, FileSource needs to have a hook to decide when it is time to stop 
> with continuous polling and then expose the end position through the 
> enumerator.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to