-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
IGNITE-23168 Event consumption time metric in CDC consumer #11612
base: master
Are you sure you want to change the base?
Conversation
7e57e9d
to
582b63f
Compare
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java
Outdated
Show resolved
Hide resolved
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java
Outdated
Show resolved
Hide resolved
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java
Outdated
Show resolved
Hide resolved
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java
Outdated
Show resolved
Hide resolved
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java
Outdated
Show resolved
Hide resolved
modules/core/src/test/java/org/apache/ignite/cdc/AbstractCdcTest.java
Outdated
Show resolved
Hide resolved
modules/core/src/test/java/org/apache/ignite/cdc/AbstractCdcTest.java
Outdated
Show resolved
Hide resolved
modules/core/src/test/java/org/apache/ignite/cdc/AbstractCdcTest.java
Outdated
Show resolved
Hide resolved
6875609
to
002aeef
Compare
ff9a0d7
to
694141b
Compare
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java
Outdated
Show resolved
Hide resolved
modules/core/src/test/java/org/apache/ignite/cdc/AbstractCdcTest.java
Outdated
Show resolved
Hide resolved
* Consumer events consumption metric
* Metrics description changed
* Histogram bounds fixed
* minor fixes
* metric units changed
* minor fixes
* redundant metric removed
* minor code style fixes
* minor code style fixes (2)
e3f7fe6
to
ba41ba1
Compare
* test refactored
* test refactored
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java
Outdated
Show resolved
Hide resolved
modules/core/src/test/java/org/apache/ignite/cdc/CdcSelfTest.java
Outdated
Show resolved
Hide resolved
modules/core/src/test/java/org/apache/ignite/cdc/CdcSelfTest.java
Outdated
Show resolved
Hide resolved
modules/core/src/test/java/org/apache/ignite/cdc/CdcSelfTest.java
Outdated
Show resolved
Hide resolved
* test refactored
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.
- Metric name is a little bit misleading
- Metric isn't updated for passive mode
* metric renamed * metric update case added
* doc & minor fixes
Done! |
@@ -125,6 +125,7 @@ The following metrics are provided by the application (additional metrics can be | |||
| BinaryMetaDir | Binary meta-directory the application reads data from. | |||
| MarshallerDir | Marshaller directory the application reads data from. | |||
| CdcDir | The CDC directory the application reads data from. | |||
| WalProcessingTime | Time of WAL segment processing, in milliseconds. |
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.
SegmentConsumingTime
} | ||
else | ||
consumeSegmentActively(builder); | ||
|
||
walProcessingTime.value(U.currentTimeMillis() - start); |
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.
code duplication
Within this commit there are 2 metrics implemented:
It will help to monitor the throughput of the transfered cache entries as well as finish time of the proccess.
Thank you for submitting the pull request to the Apache Ignite.
In order to streamline the review of the contribution
we ask you to ensure the following steps have been taken:
The Contribution Checklist
The description explains WHAT and WHY was made instead of HOW.
The following pattern must be used:
IGNITE-XXXX Change summary
whereXXXX
- number of JIRA issue.(see the Maintainers list)
the
green visa
attached to the JIRA ticket (see TC.Bot: Check PR)Notes
If you need any help, please email [email protected] or ask anу advice on http://asf.slack.com #ignite channel.