[BEAM-295] Flink Create Functions call Collector.close()

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.1.0-incubating
• Component/s: runner-flink
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 18/May/16 15:50
• Updated: 24/Jul/20 20:53
• Resolved: 01/Jun/16 10:08

Description

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.

Issue Links

• links to: GitHub Pull Request #347
• links to: GitHub Pull Request #364