I checked the code and the MapFunction InitializeWorkSet contains indeed two instances of type Either. Since we use Java serialization to ship the operators to the cluster, the MapFunction has to be serializable. Either you make the Either type serializable or you create these instances in the open method of the operator.
Cheers, Till On Mon, Nov 30, 2015 at 11:03 AM, Aljoscha Krettek <aljos...@apache.org> wrote: > It seems there is an Either.Left stored somewhere in the Object. Could > that be? > > On 28 Nov 2015, at 20:18, Vasiliki Kalavri <vasilikikala...@gmail.com> > wrote: > > > > > org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:307) > >
