Skip to content

Commit

Permalink
mend
Browse files Browse the repository at this point in the history
  • Loading branch information
noCharger committed Jan 25, 2024
1 parent 3df3a21 commit 9747f9e
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -372,7 +372,10 @@ public MetricInfo getMetricInfo(DimensionedName dimensionedName) {
Set<Dimension> dimensions = new HashSet<>();
if (doesNameConsistsOfMetricNameSpace(parts)) {
metricName = Stream.of(parts).skip(2).collect(Collectors.joining("."));
addInstanceRoleDimension(dimensions, parts);
// Exclude instance role for OpenSearch metrics
if (!parts[3].equals("opensearch")) {
addInstanceRoleDimension(dimensions, parts);
}
}
addDefaultDimensionsForSparkJobMetrics(dimensions);
dimensions.addAll(dimensionedName.getDimensions());
Expand Down

0 comments on commit 9747f9e

Please sign in to comment.