-
Notifications
You must be signed in to change notification settings - Fork 3.7k
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
Duties in Indexing group (such as Auto Compaction) does not report metrics #12352
Conversation
} else { | ||
this.duties = duties; | ||
} | ||
//Auto add emit |
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.
What does this comment mean?
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.
Done
if (DruidCoordinator.HISTORICAL_MANAGEMENT_DUTIES_DUTY_GROUP.equals(groupName)) { | ||
emitStatsForHistoricalManagementDuties(cluster, stats, emitter, params); | ||
} | ||
if (dutyList.stream().anyMatch(duty -> duty instanceof CompactSegments)) { |
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.
Instead of passing dutiesList as a parameter to the constructor, I'd recommend passing in a boolean parameter, to make it clear that this duty doesn't deal with any of the other duties. Otherwise LGTM
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.
Done
Added |
…trics (apache#12352) * add impl * add unit tests * fix checkstyle * address comments * fix checkstyle
Duties in Indexing group (such as Auto Compaction) does not report metrics
Description
Duties emit metrics via the EmitClusterStatsAndMetrics class which is run as the last duty in the group. However, this duty is only added to the HistoricalManagementDuties group and not other groups such as IndexingServiceDuties group. This PR changes the following:
This PR has: