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

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.14.0, 1.12.5, 1.13.2
• Component/s: Connectors / FileSystem
• Labels: auto-deprioritized-major pull-request-available
• Assignee: Arvid Heise
• Reporter: Yun Gao
• Created: 07/Jan/21 12:13
• Updated: 23/Sep/21 17:54
• Resolved: 01/Jul/21 09:22

Description

Currently ContinuousFileReaderOperator would close the output on close(), if it is chained with more operators, it would also 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

Issue Links

• links to: GitHub Pull Request #16271
• links to: GitHub Pull Request #16324
• links to: GitHub Pull Request #16325