Average on sliding window

Hi everyone, I’m trying to calculate an average with a sliding window. Here’s the code I’m using. First of all I receive a series of events from a Kafka topic. I declared a watermark on the ‘data_fine’ attribute. final TableDescriptor filteredPhasesDurationsTableDescriptor = TableDescriptor.fo

Checkpointed data size is zero

Hello Community, I have a requirement to read data coming over TCP socket stream and for the same written one custom source function reading data by TCP socket. Job is running successfully but in flink dashboard checkpoint overview, checkpointed data size is 0. Can you please help if there is