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
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.