pnowojski commented on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-559746061 I'm only not sure how to register a new Task `Gauge` `isBackPressured` in the `TaskIOMetricGroup`. I think this needs some refactoring in the future, but for now could you register the metric in the following way inside the `Task` constructor: ``` this.metrics = metricGroup; metricGroup.gauge("isBackPressured", new BackPressureGauge(this)); ``` Follow up work would be to introduce `TaskIOMetricGroupBuilder`, created in the `TaskExecutor`, which is passed to the `Task`. `Task` would add, the backpressure gauge to the builder and final `TaskIOMetricGroup` would be constructed/built in the `TaskExecutor` after constructing the `Task`.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
