Hi,
1- Yes. I have spaces in the job name and task. How do you configure the
metric scope for a particular job?
2- I opted for the second solution, I forked my own StatsD reporter and
squashed all spaces. Here:
https://github.com/javadevmtl/flink/blob/statsd-spaces/flink-metrics/flink-metrics-stat
I presume your job/task names contains a space, which is included in the
metrics scope?
You can either configure the metric scope such that the job/task ID is
included instead, or create a modified version of the StatsDReporter
that filters out additional characters(i.e., override #filterChara
I think I figured it out. I used netcat to debug. I think the Telegraf
StatsD server doesn't support spaces in the stats names.
On Mon, 20 Jan 2020 at 12:19, John Smith wrote:
> Hi, running Flink 1.8
>
> I'm declaring my metric as such.
>
> invalidList = getRuntimeContext()
> .getMetricGro
Hi, running Flink 1.8
I'm declaring my metric as such.
invalidList = getRuntimeContext()
.getMetricGroup()
.addGroup("MyMetrics")
.meter("invalidList", new DropwizardMeterWrapper(new
com.codahale.metrics.Meter()));
Then in my code I call.
invalidList.markEvent();
On the task
