CoGroupedStreams$TaggedUnion

[jinxw]

Whenever I use cogroup function to join two datastreams of POJOs, it seems
like internally CoGroup uses a class TaggeUnion which is not POJO and I'm
gettingg this warning

2021-05-11 16:26:08,639 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
2021-05-11 16:26:08,643 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.

There's a way to solve this?

Thank You.



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Chesnay Schepler]

Please file a ticket. This is not something you need to worry about in
terms of correctness; if anything it may impede performance (and I'm not
sure if that is the case).

On 5/11/2021 4:43 PM, jinxw wrote:

> Whenever I use cogroup function to join two datastreams of POJOs, it seems
> like internally CoGroup uses a class TaggeUnion which is not POJO and I'm
> gettingg this warning
>
> 2021-05-11 16:26:08,639 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
> 2021-05-11 16:26:08,643 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.
>
> There's a way to solve this?
>
> Thank You.
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/