[FLINK-27173] CoGroupedStreams$TaggedUnion cannot be used as a POJO type

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.14.4
• Component/s: API / Type Serialization System
• Assignee: Unassigned
• Reporter: Jun Qin
• Created: 11/Apr/22 09:54
• Updated: 11/Apr/22 10:10

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.

StreamingJob.java