Merge pull request #3607 from atlanhq/DG-1853-beta

DG-1853 Added logging
atlanhq · Oct 8, 2024 · 3f43169 · 3f43169
2 parents d6ec2ac + e4542a1
commit 3f43169
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java
@@ -4287,10 +4287,11 @@ public void updateClassificationTextPropagation(String classificationVertexId) {
                 LOG.warn("updateClassificationTextPropagation(classificationVertexId={}): classification vertex id is empty", classificationVertexId);
                 return;
             }
-
             AtlasVertex classificationVertex = graph.getVertex(classificationVertexId);
             AtlasClassification classification = entityRetriever.toAtlasClassification(classificationVertex);
+            LOG.info("Fetched classification : {} ", classification.toString());
             List<AtlasVertex> impactedVertices = graphHelper.getAllPropagatedEntityVertices(classificationVertex);
+            LOG.info("impactedVertices : {}", impactedVertices.size());
             int batchSize = 100;
             for (int i = 0; i < impactedVertices.size(); i += batchSize) {
                 int end = Math.min(i + batchSize, impactedVertices.size());
@@ -4305,6 +4306,7 @@ public void updateClassificationTextPropagation(String classificationVertexId) {
                     }
                 }
                 transactionInterceptHelper.intercept();
+                LOG.info("Updated classificationText from {} for {}", i, batchSize);
             }
         } catch (Exception e){
             e.printStackTrace();