New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
GEODE-8293: fix activeCQCount has negative value after close/stop cq for PR #5620
Conversation
Can you improve the commit message for this PR? It should include a description of what was actually changed and why it fixes the issue. Thanks! |
I don't have permission to modify your PR.
"The quantity reported for partitioned regions may be larger than that of replicated regions, as each redundant copy contributes the the count."
Thank you for your patience on completing this PR. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Docs for this PR look great. Thank you for making the changes. I approve the docs portion of this PR. I haven't looked at the code.
geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/CQMetricsDUnitTest.java
Outdated
Show resolved
Hide resolved
geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/CQMetricsDUnitTest.java
Outdated
Show resolved
Hide resolved
geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/CQMetricsDUnitTest.java
Show resolved
Hide resolved
geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/CQMetricsDUnitTest.java
Outdated
Show resolved
Hide resolved
geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/CQMetricsDUnitTest.java
Outdated
Show resolved
Hide resolved
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/ServerCQImpl.java
Outdated
Show resolved
Hide resolved
geode-cq/src/distributedTest/java/org/apache/geode/cache/query/cq/CQMetricsDUnitTest.java
Outdated
Show resolved
Hide resolved
Hi @kohlmu-pivotal , |
All changes requested are done and PR is approved, I will merge this PR. |
All changes are done and waiting for response for a long time
For partitioned regions if the CQ is registered on one server, it will be created on all the nodes/servers hosting the region.
In this case activeCQCount is increment only on one server.
After close/stop CQ it found that it has CQ on all members and decrement num of active CQs, despite of that it is only incremented on one server, so we got negative values.
With fix it will increment activeCQCount on all nodes/servers that hosting the region. So when it close/stop it will not go to the negative values.
This change will not have effects on non-partitioned(replicated) regions.
Thank you for submitting a contribution to Apache Geode.
In order to streamline the review of the contribution we ask you
to ensure the following steps have been taken:
For all changes:
Is there a JIRA ticket associated with this PR? Is it referenced in the commit message?
Has your PR been rebased against the latest commit within the target branch (typically
develop
)?Is your initial contribution a single, squashed commit?
Does
gradlew build
run cleanly?Have you written or updated unit tests to verify your changes?
If adding new dependencies to the code, are these dependencies licensed in a way that is compatible for inclusion under ASF 2.0?
Note:
Please ensure that once the PR is submitted, check Concourse for build issues and
submit an update to your PR as soon as possible. If you need help, please send an
email to dev@geode.apache.org.