Skip to content
This repository has been archived by the owner on Aug 23, 2023. It is now read-only.

clarify aggregator locking + locking bugfix #2025

Merged
merged 1 commit into from
Feb 4, 2022
Merged

Conversation

Dieterbe
Copy link
Contributor

@Dieterbe Dieterbe commented Feb 3, 2022

No description provided.

Copy link
Collaborator

@shanson7 shanson7 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM. I'm guessing this never caused an issue in practice because kafka input is given a single thread per partition, so we never really had multiple threads trying to update the same AggMetric.

@Dieterbe
Copy link
Contributor Author

Dieterbe commented Feb 4, 2022

Also, turned out the ingestFrom option wasn't that useful and I doubt anyone uses it. Anyway I think the comments around the locking are clearer now.

@Dieterbe Dieterbe merged commit 92535bc into master Feb 4, 2022
@Dieterbe Dieterbe deleted the fix-lock-aggregator branch February 4, 2022 11:16
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants