Re: Remove Accumulators at runtime
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 <pedro.mr.cha...@gmail.com> 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.
Re: Remove Accumulators at runtime
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.
Re: Remove Accumulators at runtime
Hey Pedro! No, this is not possible. What your use case for this? On Wed, Mar 8, 2017 at 10:52 AM, PedroMrChaves <pedro.mr.cha...@gmail.com> wrote: > Hello, > > We can add an accumulator using the following call: > getRuntimeContext().addAccumulator(NAME, ACCUMULATOR); > > Is there a way to remove the added accumulators at runtime? > > Regards, > Pedro Chaves > > > > - > Best Regards, > Pedro Chaves > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Remove-Accumulators-at-runtime-tp12106.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
Remove Accumulators at runtime
Hello, We can add an accumulator using the following call: getRuntimeContext().addAccumulator(NAME, ACCUMULATOR); Is there a way to remove the added accumulators at runtime? Regards, Pedro Chaves - Best Regards, Pedro Chaves -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Remove-Accumulators-at-runtime-tp12106.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
