diff --git a/ql/src/java/org/apache/hadoop/hive/ql/hooks/LineageLogger.java b/ql/src/java/org/apache/hadoop/hive/ql/hooks/LineageLogger.java index bdd98cf8a8..2f764f8a29 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/hooks/LineageLogger.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/hooks/LineageLogger.java @@ -175,7 +175,7 @@ public void run(HookContext hookContext) { List edges = getEdges(plan, index); Set vertices = getVertices(edges); - writeEdges(writer, edges); + writeEdges(writer, edges, hookContext.getConf()); writeVertices(writer, vertices); writer.endObject(); writer.close(); @@ -415,7 +415,8 @@ private String getTargetFieldName(int fieldIndex, /** * Write out an JSON array of edges. */ - private void writeEdges(JsonWriter writer, List edges) throws IOException { + private void writeEdges(JsonWriter writer, List edges, HiveConf conf) + throws IOException, InstantiationException, IllegalAccessException, ClassNotFoundException { writer.name("edges"); writer.beginArray(); for (Edge edge: edges) { @@ -433,7 +434,7 @@ private void writeEdges(JsonWriter writer, List edges) throws IOException } writer.endArray(); if (edge.expr != null) { - writer.name("expression").value(edge.expr); + writer.name("expression").value(HookUtils.redactLogString(conf, edge.expr)); } writer.name("edgeType").value(edge.type.name()); writer.endObject();