Re: Performing left join between two streams

Hi, Lalwani Flink does not support outer join on two data streams now[1], you can use the DataStream API ds1.coGroup(ds2) as a workaround. Flink SQL support outer joins well, you can also try SQL way[2]. Best, Leonard [1] https://issues.apache.org/jira/browse/FLINK-4187 [2] https://nightlie

OutOfMemoryError (java heap space) on small, local test

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,