Technologies/Apache Flink/flink_task_currentinputwatermark
Apache FlinkApache FlinkMetric

flink_task_currentinputwatermark

The last watermark this task has received. For tasks with 2 inputs this is the minimum of the last received watermarks
Dimensions:None
Available on:DatadogDatadog (1)
Interface Metrics (1)
DatadogDatadog
The last watermark this task has received. For tasks with 2 inputs this is the minimum of the last received watermarks
Dimensions:None
Sources
flink.task.currentInputWatermarkgithub.com
Related Insights (1)
Backpressure Watermark Stallcritical

Operators experiencing backpressure prevent watermarks from advancing, causing time-based operations (windows, temporal joins) to produce no results despite incoming data.

▸