When running our pipeline on Beam 2.31.0 / Flink 1.13 I see a couple of the following warnings:
10:53:31,833 INFO [16] o.a.f.a.j.t.TypeExtractor: No fields were detected for class org.apache.beam.sdk.util.WindowedValue so it cannot be used as a POJO type and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance. We do not use WindowedValue in our code directly. The problem must be somewhere in the guts of Beam. Does anyone know how this can be settled? TIA Stefan
