Re: Repeated exceptions during system metrics registration

2017-09-29 Thread Reinier Kip
Why of course... Thank you for your time. I'll figure out where to go with Beam. From: Chesnay Schepler Sent: 29 September 2017 16:41:23 To: user@flink.apache.org Subject: Re: Repeated exceptions during system metrics registration You probably have mul

Re: Repeated exceptions during system metrics registration

2017-09-29 Thread Chesnay Schepler
You probably have multiple operators that are called "Map", which causes the metric identifier to not be unique. As a result only 1 of these metrics is reported (whichever was registered first). Giving each operator a unique name will resolve this issue, but I don't know exactly how to do that

Repeated exceptions during system metrics registration

2017-09-29 Thread Reinier Kip
Hi all, I'm running a Beam pipeline on Flink and sending metrics via the Graphite reporter. I get repeated exceptions on the slaves, which try to register the same metric multiple times. Jobmanager and taskmanager data is fine: I can see JVM stuff, but only one datapoint here and there for task