Flink Create Functions call Collector.close()

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.