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
Free forum by Nabble | Edit this page |