[jira] [Created] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

[Shang Yuanchun (Jira)]

Yun Gao created FLINK-20888:
-------------------------------

             Summary: ContinuousFileReaderOperator should not close the output on close()
                 Key: FLINK-20888
                 URL: https://issues.apache.org/jira/browse/FLINK-20888
             Project: Flink
          Issue Type: Bug
          Components: Connectors / FileSystem
    Affects Versions: 1.12.0
            Reporter: Yun Gao


Currently ContinuousFileReaderOperator would close the output on close(), if it is chained with more operators, it would close the following operators before their endOfInput() is called (by default, we would call op1.endInput(), op1.close(), op2.endInput(), op2.close()... in order). This might cause some problems like in 

https://lists.apache.org/thread.html/r50a94aaea4fe25f3927a4274ea8272e6b76ecec8f3fe48d2566689bd%40%3Cuser.flink.apache.org%3E



--
This message was sent by Atlassian Jira
(v8.3.4#803005)