Hi there, I am running a local test with: * source = env.from_collection * sink = datastream.execute_and_collect with a map function between, and two very small data points in the collection
I'm able to generate an OutOfMemoryError, and due to the nature of this test using simple source and sink, plus not having large data size requirements, I suspect this is due to a bug. I'm running v1.13.2 and have created a docker-based reproduction repository here: https://github.com/mattfysh/pyflink-oom Please take a look and let me know what you think Thanks! Matt
