Re: Join with Default-Value

Posted by Gábor Gévay on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Join-with-Default-Value-tp11566p11570.html

I'm not sure what exactly is the problem, but could you check this FAQ item?
http://flink.apache.org/faq.html#why-am-i-getting-a-nonserializableexception-

Best,
Gábor



2017-02-10 14:16 GMT+01:00 Sebastian Neef <[hidden email]>:

> Hi,
>
> thanks! That's exactly what I needed.
>
> I'm not using: DataSetA.leftOuterJoin(DataSetB).where(new
> KeySelector()).equalTo(new KeySelector()).with(new JoinFunction(...)).
>
> Now I get the following error:
>
>> Caused by: org.apache.flink.optimizer.CompilerException: Error translating node 'Map "Key Extractor" : MAP [[ GlobalProperties [partitioning=RANDOM_PARTITIONED] ]] [[ LocalProperties [ordering=null, grouped=null, unique=null] ]]': Could not write the user code wrapper class org.apache.flink.api.common.operators.util.UserCodeObjectWrapper : java.io.NotSerializableException: org.apache.flink.api.java.operators.JoinOperator$EquiJoin
>
> I'm using flink-1.1.4-hd27.
>
> Any ideas how I can fix that bug? It did properly work with a simple .join()
>
> Regards,
> Sebastian