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 https://issues.apache.org/jira/browse/FLINK-10135 Thanks, Steven