commit 013c8623e919b9442b440df9a605be343632dc2b
author radhikakundam <radhikakundam@apache.org> Mon Mar 13 16:05:09 2023 -0700
committer radhikakundam <radhikakundam@apache.org> Mon Mar 27 14:36:46 2023 -0700
tree af60d955097e6b5cf4f5a839aea64bddc9ab4807
parent c78f3cb1af4f5b15bbd092d45d0cb7b6cc763843

ATLAS-4734: HiveProcess - Output entity creation is ignored in case of same entity exists both inputs and outputs from context

addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/CreateHiveProcess.java

diff --git a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/CreateHiveProcess.java b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/CreateHiveProcess.java
index 5787c93..bc2c91a 100644
--- a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/CreateHiveProcess.java
+++ b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/CreateHiveProcess.java
@@ -70,9 +70,10 @@
         AtlasEntitiesWithExtInfo ret = null;
 
         if (!skipProcess()) {
-            List<AtlasEntity> inputs         = new ArrayList<>();
-            List<AtlasEntity> outputs        = new ArrayList<>();
-            Set<String>       processedNames = new HashSet<>();
+            List<AtlasEntity> inputs              = new ArrayList<>();
+            List<AtlasEntity> outputs             = new ArrayList<>();
+            Set<String>       processedInputNames = new HashSet<>();
+            Set<String>       processedOutputNames = new HashSet<>();
 
             ret = new AtlasEntitiesWithExtInfo();
 
@@ -80,7 +81,7 @@
                 for (ReadEntity input : getInputs()) {
                     String qualifiedName = getQualifiedName(input);
 
-                    if (qualifiedName == null || !processedNames.add(qualifiedName)) {
+                    if (qualifiedName == null || !processedInputNames.add(qualifiedName)) {
                         continue;
                     }
 
@@ -100,7 +101,7 @@
                 for (WriteEntity output : getOutputs()) {
                     String qualifiedName = getQualifiedName(output);
 
-                    if (qualifiedName == null || !processedNames.add(qualifiedName)) {
+                    if (qualifiedName == null || !processedOutputNames.add(qualifiedName)) {
                         continue;
                     }