You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jun Qin (Jira)" <ji...@apache.org> on 2022/04/11 09:55:00 UTC
[jira] [Created] (FLINK-27173) CoGroupedStreams$TaggedUnion cannot be used as a POJO type
Jun Qin created FLINK-27173:
-------------------------------
Summary: 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
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)