We're running a pipeline which we previously ran with a local Spark runner but now have switched to instead use a local Flink runner. With the Spark runner we have been getting Beam metrics by using the org.apache.beam.runners.extensions.metrics.MetricsGraphiteSink. When we switched over to instead using Flink, we stopped getting the metrics from Beam. Is there a way around this problem or can someone point me in a direction where I can find some info on how to set it up?
For some background; our set up is in Kubernetes where we have a sidecar container running Graphite where our Beam-pipeline is running in another container in the same pod, which is pushing metrics over localhost to the Graphite container. // Lars
