@zorro786 I definitely lack terminology so I apologise if I confuse apples and 
pears. I thought they are sort of equivalent, in a sense, that what is 
accumulators is also published as metrics. This is what I guessed from 
`FlinkMetricContainer` updates here
https://github.com/apache/beam/blob/master/runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainer.java#L86

It they are not equivalent in values, that whole idea of possibility to use 
flink's `MetricReporter` is wrong.

[ Full content available at: https://github.com/apache/beam/pull/4548 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to