You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by laxmi narayan <ni...@gmail.com> on 2022/06/30 14:12:51 UTC

How to store AvroSchema POJOs in state-store ?

Hi ,
I am unable to store Avro-schema based events in the state store, I am
using the following configurations.

I see the doc says,
<https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/fault-tolerance/serialization/schema_evolution/>
currently Avro is  supported by default, is that correct?

private transient ValueState<AvroProcessed> IN_MEMORY_DB;
@Override
public void open(Configuration parameters) {
    IN_MEMORY_DB = getRuntimeContext().getState(new
ValueStateDescriptor<>("data-cache",
TypeInformation.of(AvroProcessed.class)));
}







Thank you.