I see, this is not possible with accumulators. You could wrap all counts in a single metric and update that one. Check out Flink's metrics:
https://ci.apache.org/projects/flink/flink-docs-release-1.2/monitoring/metrics.html On Wed, Mar 8, 2017 at 5:04 PM, PedroMrChaves <[email protected]> wrote: > Hi, > > I'm building a system that maintains a set of rules that can be dynamically > added/removed. I wanted to count every element that matched each rule in an > accumulator ( I have several parallel instances). If the rule is removed so > should the accumulator. > > > > > > ----- > Best Regards, > Pedro Chaves > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Remove-Accumulators-at-runtime-tp12106p12119.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
