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

Posted to issues@flink.apache.org by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/01/07 12:38:00 UTC

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

    [ https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260476#comment-17260476 ] 

Arvid Heise commented on FLINK-20888:
-------------------------------------

Thanks for the investigation, we would take it on soonish.

> 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
>            Priority: Major
>
> 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]



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