[jira] [Created] (FLINK-4433) Refactor the StreamSource.

[Shang Yuanchun (Jira)]

Kostas Kloudas created FLINK-4433:
-------------------------------------

             Summary: Refactor the StreamSource.
                 Key: FLINK-4433
                 URL: https://issues.apache.org/jira/browse/FLINK-4433
             Project: Flink
          Issue Type: Bug
            Reporter: Kostas Kloudas


With the addition of continuous file monitoring, apart from the {{StreamSource}} also the {{ContinuousFileReaderOperator}} uses a {{SourceContext}}. Given this, all the implementations of the {{SourceContext}} should be removed from the {{StreamSource}} and become independent classes.

In addition, the {{AsyncExceptionChecker}} interface should be removed as its functionality can be replaced by the {{task.failExternally()}} method. This also implies slight changes in the source context implementations.




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)