[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

backpressure metrics

Flink has two backpressure related metrics: lastCheckpointAlignmentBuffered” and “checkpointAlignmentTime”. But they seems to always report zero. Similar thing in web UI, “Buffered During Alignment” always shows zero, even backpressure testing shows high backpressure for some operators. Has anyone else seen similar problem?

We are running flink 1.4.0 with some cherry-picked fixes. there was a bug and fix for 1.5 and above, which shouldn't affect us