diff --git a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java index 7dc2e2f1b..4dc5fc402 100755 --- a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java +++ b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java @@ -664,14 +664,15 @@ private void registerProcess(HiveMetaStoreBridge dgiBridge, HiveEventContext eve sortedHiveOutputs.addAll(event.getOutputs()); } - for (ReadEntity readEntity : sortedHiveInputs) { - processHiveEntity(dgiBridge, event, readEntity, dataSets, source, entities); - } for (WriteEntity writeEntity : sortedHiveOutputs) { processHiveEntity(dgiBridge, event, writeEntity, dataSets, target, entities); } + for (ReadEntity readEntity : sortedHiveInputs) { + processHiveEntity(dgiBridge, event, readEntity, dataSets, source, entities); + } + if (source.size() > 0 || target.size() > 0) { Referenceable processReferenceable = getProcessReferenceable(dgiBridge, event, sortedHiveInputs, sortedHiveOutputs, source, target); // setup Column Lineage