[jira] [Commented] (FLINK-27173) CoGroupedStreams$TaggedUnion cannot be used as a POJO type

["Jun Qin (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-27173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520475#comment-17520475 ] 

Jun Qin commented on FLINK-27173:
---------------------------------

As Flink uses {{CoGroupedStreams$UnionSerializer}} as a custom serializer for {{CoGroupedStreams$TaggedUnion}}, there is actually no performance issue here, so this JIRA is only to remove the confusing log message.

> CoGroupedStreams$TaggedUnion cannot be used as a POJO type
> ----------------------------------------------------------
>
>                 Key: FLINK-27173
>                 URL: https://issues.apache.org/jira/browse/FLINK-27173
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Type Serialization System
>    Affects Versions: 1.14.4
>            Reporter: Jun Qin
>            Priority: Major
>         Attachments: StreamingJob.java
>
>
> Attached is the code to demo the issue.  When running the job, we can see the following:
> {code:java}
> 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. {code}
> TaggedUnion is a class in Flink. This should be fixed in Flink.
> [^StreamingJob.java]



--
This message was sent by Atlassian Jira
(v8.20.1#820001)