Hi, Matt I’ve checked your job is pretty simple, I've CC Xingbo who is a PyFlink expert to help take a quick look.
Best， Leonard > 2022年10月31日 上午11:47，Matt Fysh <mattf...@gmail.com> 写道： > > 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 > <https://github.com/mattfysh/pyflink-oom> > > Please take a look and let me know what you think > > Thanks! > Matt
