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)
