Hey there, is there a way that I can measure how m...
# troubleshooting
f
Hey there, is there a way that I can measure how many late arrival events occur in PyFlink on 1.15?
afaik there is no metric out of the box for this. would a windowed stream with a side output for late events and a counter metric be a possible option for this?
cc'ing my teammate @Sajid Samsad
πŸ‘ 1
s
From https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/ops/metrics/#io
Copy code
numLateRecordsDropped

The number of records this operator/task has dropped due to arriving late.
so might be relevant.
f
this looks great. thank you πŸ™‚