For the 'Requested array size exceeds VM limit' error, can you pastebin the full stack trace ?
Thanks On Wed, Jun 14, 2017 at 3:22 AM, Sebastian Neef < gehax...@mailbox.tu-berlin.de> wrote: > 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 >
