Re: Either not NotSerializableException and InvalidTypesException

It seems there is an Either.Left stored somewhere in the Object. Could that be? > On 28 Nov 2015, at 20:18, Vasiliki Kalavri wrote: > > org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:307)

Re: Either not NotSerializableException and InvalidTypesException

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

Re: Either not NotSerializableException and InvalidTypesException

Hi Vasia, regarding your TypeExtractor problem. The TypeExtractor works correctly. The with() function of the JoinOperator calls the wrong TypeExtractor method that does not allow missing type info. This is a bug. Can open an issue for that? Regards, Timo On 28.11.2015 20:18, Vasiliki