Hi Chesnay,
I do not want to store metric counter in reference variable because I want
to create metric counter for every key of keyed stream.
There can be n number of keys and I do not want to have n number of
references.
On Tue, 8 Jan, 2019, 11:01 PM Chesnay Schepler What you're trying to do
What you're trying to do is not possible. Even if you close the group
/it still exists/, and is returned by subsequent calls to
addGroup("mygroup").
However since it is closed all registration calls will be ignored, hence
why the value isn't updating.
You can only update a metric by storing a
Hi Chesnay,
If removing the metrics is not possible from Flink GUI, while the job is
running.
Then kindly tell me how to update a metric counter.
Explaination:
Suppose I created a metric Counter with key "chesnay" and incremented the
counter to 20, by code mentioned below.
getRuntimeContext().get
Metrics for a given job will be available in the GUI until the Job has
finished.
On 08.01.2019 17:08, Gaurav Luthra wrote:
Hi,
I am using ProcessWindowFunction, and in process() function I am
adding user scoped Group as mentioned below.
MetricGroup myMetricGroup=
getRuntimeContext().getMetri
Hi,
I am using ProcessWindowFunction, and in process() function I am adding
user scoped Group as mentioned below.
MetricGroup myMetricGroup = getRuntimeContext().getMetricGroup().addGroup(
"myGroup")
Now, I am creating counter metrics using my myMetricGroup, and I am able to
see these counters in
