Hi, I removed the .distinct() and ran another test.
Without filtering duplicate entries, the Job processes more data and runs much longer, but eventually fails with the following error: > java.lang.OutOfMemoryError: Requested array size exceeds VM limit Even then playing around with the aforementioned Flink settings does not resolve the problem. I guess, I need to debug this some more. Best, Sebastian
