I am trying to measure the currentLowWatermark throughout my dataflow, but I am not seeing it for tasks with sources. For those tasks I see these metrics:
lastCheckpointSize numBytesInLocal numBytesInRemote numBytesOut why am I not seeing currentLowWatermark on these tasks? Thanks! Dan
