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

Reply via email to