You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by sa...@apache.org on 2021/05/12 21:44:55 UTC

[atlas] branch master updated: ATLAS-4284: Hive pruned tables are ignored and not pruned

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 81888a9  ATLAS-4284: Hive pruned tables are ignored and not pruned
81888a9 is described below

commit 81888a9c7772b83437d009071e91fbd2a13cc831
Author: Radhika Kundam <rk...@cloudera.com>
AuthorDate: Wed May 12 13:55:08 2021 -0700

    ATLAS-4284: Hive pruned tables are ignored and not pruned
    
    Signed-off-by: Sarath Subramanian <sa...@apache.org>
---
 .../org/apache/atlas/notification/preprocessor/HivePreprocessor.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/webapp/src/main/java/org/apache/atlas/notification/preprocessor/HivePreprocessor.java b/webapp/src/main/java/org/apache/atlas/notification/preprocessor/HivePreprocessor.java
index e69d63e..86e3384 100644
--- a/webapp/src/main/java/org/apache/atlas/notification/preprocessor/HivePreprocessor.java
+++ b/webapp/src/main/java/org/apache/atlas/notification/preprocessor/HivePreprocessor.java
@@ -81,6 +81,10 @@ public class HivePreprocessor {
                     entity.setAttribute(ATTRIBUTE_SD, null);
                     entity.setAttribute(ATTRIBUTE_COLUMNS, null);
                     entity.setAttribute(ATTRIBUTE_PARTITION_KEYS, null);
+
+                    entity.setRelationshipAttribute(ATTRIBUTE_SD, null);
+                    entity.setRelationshipAttribute(ATTRIBUTE_COLUMNS, null);
+                    entity.setRelationshipAttribute(ATTRIBUTE_PARTITION_KEYS, null);
                 } else if (context.getHiveTypesRemoveOwnedRefAttrs()) {
                     context.removeRefAttributeAndRegisterToMove(entity, ATTRIBUTE_SD, RELATIONSHIP_TYPE_HIVE_TABLE_STORAGEDESC, ATTRIBUTE_TABLE);
                     context.removeRefAttributeAndRegisterToMove(entity, ATTRIBUTE_COLUMNS, RELATIONSHIP_TYPE_HIVE_TABLE_COLUMNS, ATTRIBUTE_TABLE);