Re: How to test serializability of a Flink job

2016-04-09 Thread Robert Metzger
Hi Simone, do you have a stack trace for the error? Usually the user code serialization is the same locally and on a cluster. On Tue, Apr 5, 2016 at 12:02 PM, Simone Robutti < simone.robu...@radicalbit.io> wrote: > Hello, > > last week I got a problem where my job worked in local mode but could

How to test serializability of a Flink job

2016-04-05 Thread Simone Robutti
Hello, last week I got a problem where my job worked in local mode but could not be serialized on the cluster. I assume that local mode does not really serialize all the operators (the problem was with a custom map function) and I need to enforce this behaviour in local mode or, better, be able to