Re: The implementation of the CoGroupFunction is not serializable

2017-05-01 Thread Kaepke, Marc
ot; org.apache.flink.api.common.InvalidProgramException: The implementation of the CoGroupFunction is not serializable. The object probably contains or references non serializable fields. at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:100) at org.a

The implementation of the CoGroupFunction is not serializable

2017-04-30 Thread Kaepke, Marc
nk.api.common.InvalidProgramException: The implementation of the CoGroupFunction is not serializable. The object probably contains or references non serializable fields. at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:100) at org.apache.flink.