Skip to content

A
atlas
Commit e7eaa996 by ashutoshm Committed by Madhan Neethiraj
Options

ATLAS-1583: fix incorrect metrics by import API

Signed-off-by: 's avatarMadhan Neethiraj <madhan@apache.org>
parent 2904f4c4
Showing with 5 additions and 1 deletion
repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1.java
...@@ -186,6 +186,10 @@ public class AtlasEntityStoreV1 implements AtlasEntityStore { ...@@ -186,6 +186,10 @@ public class AtlasEntityStoreV1 implements AtlasEntityStore {
} }
for (AtlasEntityHeader h : list) { for (AtlasEntityHeader h : list) {
if(processedGuids.contains(h.getGuid())) {
continue;
}
processedGuids.add(h.getGuid()); processedGuids.add(h.getGuid());
importResult.incrementMeticsCounter(String.format(prefix, h.getTypeName())); importResult.incrementMeticsCounter(String.format(prefix, h.getTypeName()));
} }
......
webapp/src/main/java/org/apache/atlas/web/resources/ImportService.java
...@@ -139,6 +139,6 @@ public class ImportService { ...@@ -139,6 +139,6 @@ public class ImportService {
this.entityStore.bulkImport(importSource, result); this.entityStore.bulkImport(importSource, result);
endTimestamp = System.currentTimeMillis(); endTimestamp = System.currentTimeMillis();
result.incrementMeticsCounter("Duration", (int) (this.endTimestamp - this.startTimestamp)); result.incrementMeticsCounter("duration", (int) (this.endTimestamp - this.startTimestamp));
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment