Skip to content

Commit b34ec9a

Browse files
committed
refactored some missing logic.
1 parent 42e4700 commit b34ec9a

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

repository/src/main/java/org/apache/atlas/tasks/TaskRegistry.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
import org.apache.atlas.repository.graphdb.DirectIndexQueryResult;
3636
import org.apache.atlas.repository.graphdb.janus.AtlasElasticsearchQuery;
3737
import org.apache.atlas.type.AtlasType;
38+
import org.apache.atlas.utils.AtlasMetricType;
3839
import org.apache.atlas.utils.AtlasPerfMetrics;
3940
import org.apache.commons.collections.CollectionUtils;
4041
import org.apache.commons.collections4.ListUtils;
@@ -466,11 +467,12 @@ public List<AtlasTask> getTasksForReQueueIndexSearch() {
466467
}
467468
}
468469
if(mismatches > 0) {
469-
AtlasPerfMetrics.Metric indexsearchMetric = new AtlasPerfMetrics.Metric(TASK_MISMATCH_TAG);
470-
indexsearchMetric.addTag("name", TASK_MISMATCH_TAG);
471-
indexsearchMetric.setInvocations(mismatches);
472-
indexsearchMetric.setTotalTimeMSecs(0);
473-
RequestContext.get().addApplicationMetrics(indexsearchMetric);
470+
AtlasPerfMetrics.Metric mismatchMetrics = new AtlasPerfMetrics.Metric(TASK_MISMATCH_TAG);
471+
mismatchMetrics.setMetricType(AtlasMetricType.COUNTER);
472+
mismatchMetrics.addTag("name", TASK_MISMATCH_TAG);
473+
mismatchMetrics.setInvocations(mismatches);
474+
mismatchMetrics.setTotalTimeMSecs(0);
475+
RequestContext.get().addApplicationMetrics(mismatchMetrics);
474476
}
475477
return ret;
476478
}

0 commit comments

Comments
 (0)