Aljoscha Krettek created BEAM-295: ------------------------------------- Summary: Flink Create Functions call Collector.close() Key: BEAM-295 URL: https://issues.apache.org/jira/browse/BEAM-295 Project: Beam Issue Type: Bug Components: runner-flink Reporter: Aljoscha Krettek Assignee: Aljoscha Krettek
{{Collector.close()}} should only be called internally, by Flink. Calling close() in the user function, as we do in {{FlinkCreateFunction}} and {{FlinkStreamingCreateFunction}} will lead to downstream operations being closed twice, which can lead to faulty behavior. -- This message was sent by Atlassian JIRA (v6.3.4#6332)