Hi Kirill, as far as I know SpecificRecordBase should work in Flink, I
don't know if there's any limitation in StateFun.
It seems that the typeClass passed to the generateFieldsFromAvroSchema from
the PravegaDeserializationSchema..
Maybe the pravega.LoadsSource does not bind correctly the Avro clas
Hello
I read in this article
https://flink.apache.org/news/2020/04/15/flink-serialization-tuning-vol-1.html
that it's possible to use SpecificRecordBase.class in the operators:
Avro Specific
Avro specific records will be automatically detected by checking that the given
type’s type hierarchy c
