pnowojski commented on PR #20337: URL: https://github.com/apache/flink/pull/20337#issuecomment-1205325558
Hi @nyingping . After giving this a second look I think the current code behaviour is indeed correct and I don't see any bug here. You idle source subtasks have never sent any watermark to some of the downstream local aggregations. So those `LocalWindowAggregate` correctly don't report any watermark, resulting in `Low Watermark` in the webUI not being reported. As correctly, low watermark is `NaN` for the task as a whole. It might be a bit confusing the current behaviour. Ideally maybe WebUI should present the lowest non `NaN` watermark, with a caveate/asteriks, that some subtasks are idle. But to me the current behaviour is also valid. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
