Re: Metrics with labels

2023-10-30 Thread Lars Skjærven
Registering the counter is fine, e.g. in `open()`: lazy val responseCounter: Counter = getRuntimeContext .getMetricGroup .addGroup("response_code") .counter("myResponseCounter") then, in def asyncInvoke(), I can still only do responseCounter.inc(), but what I want is responseCou

Re: Metrics with labels

2023-10-17 Thread Chesnay Schepler
> I think this is a general issue with the Flink metrics. Not quite. There are a few instance in Flink were code wasn't updated to encode metadata as additional labels, and the RocksDB metrics may be one of them. Also for RocksDB, you could try setting "state.backend.rocksdb.metrics.column-fam

Metrics with labels

2023-10-17 Thread Lars Skjærven
Hello, We're experiencing difficulties in using Flink metrics in a generic way since various properties are included in the name of the metric itself. This makes it difficult to generate sensible (and general) dashboards (with aggregations). One example is the metric for rocksdb estimated live da