2020. 21:19
Prima: dev@geode.apache.org
Predmet: Re: negative ActiveCQCount
Mario,
Here is how the CQ register behaves:
When there is a single client and two servers.
When CQ is registered, with redundancy 0:
- On non-partitioned region, the CQ gets registered on one server, through
registerCQ
Hi devs,
Just reminder if someone is familiar with this, or someone has some idea how to
resolve this issue.
Thanks and BR,
Mario
Šalje: Mario Kevo
Poslano: 7. srpnja 2020. 15:24
Prima: dev@geode.apache.org
Predmet: Odg: Odg: negative ActiveCQCount
Hi,
Thank
Šalje: Kirk Lund
Poslano: 1. srpnja 2020. 19:52
Prima: dev@geode.apache.org
Predmet: Re: Odg: negative ActiveCQCount
Yeah, https://issues.apache.org/jira/browse/GEODE-8293 sounds like a
statistic decrement bug for activeCqCount. Somewhere, each Server is
decrementing it once too
of ServerCqImpl). When we close CQ there is two different
> instances on servers and it closed both of them, but as they are in RUNNING
> state before closing, it decrements activeCqCount on both of them.
>
> BR,
> Mario
>
> ____
> Šalje: Kirk Lund
> Poslano: 3
, it
decrements activeCqCount on both of them.
BR,
Mario
Šalje: Kirk Lund
Poslano: 30. lipnja 2020. 19:54
Prima: dev@geode.apache.org
Predmet: Re: negative ActiveCQCount
I think *show metrics --categories=query* is showing you the quer
lipnja 2020. 19:54
Prima: dev@geode.apache.org
Predmet: Re: negative ActiveCQCount
I think *show metrics --categories=query* is showing you the query stats
from DistributedSystemMXBean (see
ShowMetricsCommand#writeSystemWideMetricValues). DistributedSystemMXBean
aggregates values across all m
I think *show metrics --categories=query* is showing you the query stats
from DistributedSystemMXBean (see
ShowMetricsCommand#writeSystemWideMetricValues). DistributedSystemMXBean
aggregates values across all members in the cluster, so I would have
expected activeCQCount to initially show a value
Hi geode-dev,
I have a question about CQ(https://issues.apache.org/jira/browse/GEODE-8293).
If we run CQ it register cq on one of the servers(setPoolSubscriptionRedundancy
is 1) and increment activeCQCount.
As I understand then it processInputBuffer to another server and there is