You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2019/09/19 13:26:45 UTC

[GitHub] [flink] pnowojski commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

pnowojski commented on issue #9646:  [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor
URL: https://github.com/apache/flink/pull/9646#issuecomment-533129802
 
 
   I agree with @StephanEwen
   > I think in that case there should be a placeholder interface in flink-runtime that is used, instead of a preliminary version of SourceReader. That placeholder gets refactored/replaced by the proper source reader then.
   >
   > That placeholder should also have only the necessary methods, nothing about splits, start, etc
   
   With defining this place holder interface, I think we could work on this PR. We might need to reconsider regarding the splits if we want also to follow up with runtime support for stateful `SourceReader` in some next PR. 

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services