I’m having difficulty accessing Beam metrics when using FlinkRunner in streaming mode. I don’t get any metrics from MetricsPusher, though the same setup delivered metrics from SparkRunner. Probably for the same reason that MetricsPusher doesn’t work, I also don’t get any output when I call an instance of MetricsHttpSink directly. The problem seems to be that Flink never returns from pipeline.run(), an issue that others have referred to as FlinkRunner hanging.
Is there a solution for getting metrics in this case that I’m missing? Thanks! -Phil
