ATLAS-2891: updated hook notification processing with option to ignore…

ATLAS-2891: updated hook notification processing with option to ignore potentially incorrect hive_column_lineage - #2 (cherry picked from commit be6a4ffa053cf5e8eed431ac07a104a31e55c1e2)

ATLAS-2891: updated hook notification processing with option to ignore…
20367512 · Madhan Neethiraj · ab801ff2 · 20367512
Commit 20367512 authored Oct 10, 2018 by Madhan Neethiraj
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

CreateHiveProcess.java .../org/apache/atlas/hive/hook/events/CreateHiveProcess.java +1 -1

No files found.
--- 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
@@ -192,7 +192,7 @@ public class CreateHiveProcess extends BaseHiveEvent {
            columnLineages.add(columnLineageProcess);
        }

-        boolean skipColumnLineage = context.getSkipHiveColumnLineageHive20633() && isSameInputsSize && lineageInputsSize > context.getSkipHiveColumnLineageHive20633InputsThreshold();
+        boolean skipColumnLineage = context.getSkipHiveColumnLineageHive20633() && columnLineages.size() > 1 && isSameInputsSize && lineageInputsSize > context.getSkipHiveColumnLineageHive20633InputsThreshold();

        if (!skipColumnLineage) {
            for (AtlasEntity columnLineage : columnLineages) {