diff --git a/.github/workflows/maven.yml b/.github/workflows/maven.yml index a12a2505a4..0977cb36a2 100644 --- a/.github/workflows/maven.yml +++ b/.github/workflows/maven.yml @@ -25,7 +25,7 @@ on: - beta - development - master - - tagcleanup + - lineageondemand jobs: build: diff --git a/repository/src/main/java/org/apache/atlas/repository/graph/GraphHelper.java b/repository/src/main/java/org/apache/atlas/repository/graph/GraphHelper.java index 9c687c0072..179d915df9 100755 --- a/repository/src/main/java/org/apache/atlas/repository/graph/GraphHelper.java +++ b/repository/src/main/java/org/apache/atlas/repository/graph/GraphHelper.java @@ -391,7 +391,7 @@ public static List getAllAssetsWithClassificationAttached(AtlasGrap return Collections.emptyList(); } List classificationVerticesList = IteratorUtils.toList(classificationVertices.iterator()); - LOG.info("classificationVerticesList size: {}", classificationVerticesList.size()); + LOG.info("classificationVerticesList size: {}", classificationVerticesList.size()); HashSet entityVerticesSet = new HashSet<>(); for (AtlasVertex classificationVertex : classificationVerticesList) { Iterable attachedVertices = classificationVertex.query() @@ -402,7 +402,7 @@ public static List getAllAssetsWithClassificationAttached(AtlasGrap while (attachedVerticesIterator.hasNext()) { entityVerticesSet.add(attachedVerticesIterator.next()); } - LOG.info("classificationVerticesSet size: {}", entityVerticesSet.size()); + LOG.info("entityVerticesSet size: {}", entityVerticesSet.size()); } } 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 index 3e473733a3..97ff277872 100644 --- 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 @@ -3007,7 +3007,7 @@ public void cleanUpClassificationPropagation(String classificationName) throws A offset += CHUNK_SIZE; } finally { transactionInterceptHelper.intercept(); - LOG.info("Cleaned up {} entities", offset); + LOG.info("Cleaned up {} entities for classification {}", offset, classificationName); } } while (offset < totalVertexSize);