Avro SpecificRecordBase question

flink-core.jar:3.0.0] Did I miss something? Is it possible to use SpecificRecordBase.class as a SourceFunction/SinkFunction type? Hope it was clear Thanks -- Best regards, Kirill Kosenko

Checkpoints question

Hello I'm new to Flink. I am playing with Stateful Functions and have a question about checkpoints and how they work. Some configuration details: state.backend: rocksdb state.backend.incremental: true execution.checkpointing.mode: AT_LEAST_ONCE As far as I know: 1. There is a sync checkp