So my flatmap function processes input event which contain some domain
specific value, and I need to keep track how much of this value has been
processed with the invocations of the flatmap. Hence I am having a class
variable which I then update whenever function is invoked, and set it to
gauge.
Ea
Hi Manish,
This approach sounds fishy. Shouldn't all instances of the function on the
same task manager then have the same value?
Why do you need the variable? What's not working when updating the gauge
directly?
On Fri, Jan 15, 2021 at 4:46 AM Manish G
wrote:
> Hi All,
>
> I have few RichFlat
Hi All,
I have few RichFlatMapFunction classes, and I have gauge added to each one
of them. For a particular usecase I am updating these gauges
incrementally. I have a class member variable in each of these classes
which keeps increasing as flapMap function in these classes is called, and
then I
