Re: Flink metrics reporters documentation

2019-10-10 Thread Aleksey Pak
Hi Flavio, Below is my explanation to your question, based on anecdotal evidence: As you may know, Flink distribution package is already scala version specific and bundles some jar artifacts. User Flink job is supposed to be compiled against some of those jars (with maven's `provided` scope). For

Re: Flink metrics reporters documentation

2019-10-10 Thread Flavio Pompermaier
Sorry, I just discovered that those jars are actually in the opt folder within Flink dist..however the second point still holds: why there's a single influxdb jar inside flink's opt jar while on maven there are 2 versions (one for scala 2.11 and one for 2.12)? Best, Flavio On Thu, Oct 10, 2019 at

Flink metrics reporters documentation

2019-10-10 Thread Flavio Pompermaier
Hi to all, I was trying to configure monitoring on my cluster so I went to the metric reporters documentation. There are 2 things that are not clear to me: 1. In all reporters the documentation says to take the jars from /opt folder..obviously this is not true. Wouldn't be better to provide