-
Notifications
You must be signed in to change notification settings - Fork 3.8k
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
changefeedccl: add parallel io metrics #115785
Conversation
c54b31b
to
97a9b56
Compare
81467d3
to
abeaf47
Compare
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.
Reviewable status: complete! 0 of 0 LGTMs obtained
11a6b32
to
4ca6d2d
Compare
This change adds metrics to improve the observability of contention in the batching webhook and pubsub sinks. Previously, there were no metrics to count the number of pending and in-flight keys, so this change adds `changefeed.parallel_io_pending_keys` and `changefeed.parallel_io_result_queue_nanos` to measure them respectively. This change also adds `changefeed.parallel_io_result_queue_nanos` to measure the time which results from the sink must wait in a queue before the changefeed acks them. Release note: None Closes: cockroachdb#114140 Epic: None
4ca6d2d
to
b90e6fe
Compare
bors r+ |
Build succeeded: |
blathers backport 23.2 |
Encountered an error creating backports. Some common things that can go wrong:
You might need to create your backport manually using the backport tool. error creating merge commit from b90e6fe to blathers/backport-release-23.2-115785: POST https://api.github.com/repos/cockroachdb/cockroach/merges: 409 Merge conflict [] you may need to manually resolve merge conflicts with the backport tool. Backport to branch 23.2 failed. See errors above. 🦉 Hoot! I am a Blathers, a bot for CockroachDB. My owner is dev-inf. |
This change adds metrics to improve the observability of contention in
the batching webhook and pubsub sinks.
Previously, there were no metrics to count the number of pending and in-flight keys,
so this change adds
changefeed.parallel_io_pending_keys
andchangefeed.parallel_io_result_queue_nanos
to measure them respectively.This change also adds
changefeed.parallel_io_result_queue_nanos
to measurethe time which results from the sink must wait in a queue before the changefeed
acks them.
Release note: None