Hi, thanks a lot for your answers :)
@Timo: sure, I can open an issue, but I'm not sure I understand the problem to describe it properly. The with() method calls the getFlatJoinReturnTypes() with the allowMissing parameter set to false. Is this what you're referring to? What does this parameter do and when should it be true/false? Thanks! @Till: thanks for the explanation Till. I didn't realize Java serialization was involved there! Cheers, -V. On 30 November 2015 at 11:09, Till Rohrmann <trohrm...@apache.org> wrote: > 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) > > > > >
