Whenever I use cogroup function to join two datastreams of POJOs, it seems like internally CoGroup uses a class TaggeUnion which is not POJO and I'm gettingg this warning
2021-05-11 16:26:08,639 INFO org.apache.flink.api.java.typeutils.TypeExtractor [] - class org.apache.flink.streaming.api.datastream.CoGroupedStreams$TaggedUnion does not contain a setter for field one 2021-05-11 16:26:08,643 INFO org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class org.apache.flink.streaming.api.datastream.CoGroupedStreams$TaggedUnion cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance. There's a way to solve this? Thank You. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
