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
