[
https://issues.apache.org/jira/browse/FLINK-27173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Qin updated FLINK-27173:
----------------------------
Description:
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]
was:
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]
> 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)
