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 <gehax...@mailbox.tu-berlin.de>: > 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
