@JozoVilcek thanks for the contribution ! And welcome abord ! @JozoVilcek @mxm `FlinkMetricsContainer` backs a `MetricsContainer` and there is one `MetricsContainer` per bundle x step. Also `DoFnRunnerWithMetricsUpdate` runs for a particular step to which the `FlinkMetricsContainer` is scoped to. So I think it is makes a lot of sense. LGTM also.
[ Full content available at: https://github.com/apache/beam/pull/6319 ] This message was relayed via gitbox.apache.org for [email protected]
