[nifi] branch master updated: NIFI-6945: Use minExtInfo=true to reduce the amount of data queried from Atlas

[mcgilman]

This is an automated email from the ASF dual-hosted git repository.

mcgilman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/master by this push:
     new b8ffb54  NIFI-6945: Use minExtInfo=true to reduce the amount of data 
queried from Atlas
b8ffb54 is described below

commit b8ffb5461216b8330fb464162316197458f482c7
Author: Peter Turcsanyi <turcsa...@apache.org>
AuthorDate: Fri Dec 20 16:14:12 2019 +0100

    NIFI-6945: Use minExtInfo=true to reduce the amount of data queried from 
Atlas
    
    This closes #3970
---
 .../src/main/java/org/apache/nifi/atlas/NiFiAtlasClient.java          | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/main/java/org/apache/nifi/atlas/NiFiAtlasClient.java
 
b/nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/main/java/org/apache/nifi/atlas/NiFiAtlasClient.java
index 4e95a92..49eacd1 100644
--- 
a/nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/main/java/org/apache/nifi/atlas/NiFiAtlasClient.java
+++ 
b/nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/main/java/org/apache/nifi/atlas/NiFiAtlasClient.java
@@ -493,12 +493,12 @@ public class NiFiAtlasClient {
     public AtlasEntity.AtlasEntityWithExtInfo searchEntityDef(AtlasObjectId 
id) throws AtlasServiceException {
         final String guid = id.getGuid();
         if (!StringUtils.isEmpty(guid)) {
-            return atlasClient.getEntityByGuid(guid);
+            return atlasClient.getEntityByGuid(guid, true, false);
         }
         final Map<String, String> attributes = new HashMap<>();
         id.getUniqueAttributes().entrySet().stream().filter(entry -> 
entry.getValue() != null)
                 .forEach(entry -> attributes.put(entry.getKey(), 
entry.getValue().toString()));
-        return atlasClient.getEntityByAttribute(id.getTypeName(), attributes);
+        return atlasClient.getEntityByAttribute(id.getTypeName(), attributes, 
true, false);
     }
 
 }