Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.14.4
-
None
-
None
Description
Attached is the code to demo the issue. When running the job, we can see the following:
11:48:26,584 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 11:48:26,586 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.
TaggedUnion is a class in Flink. This should be fixed in Flink.