Re: Join with Default-Value

Posted by Sebastian Neef on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Join-with-Default-Value-tp11566p11569.html

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