diff --git ql/src/java/org/apache/hadoop/hive/ql/plan/TezWork.java ql/src/java/org/apache/hadoop/hive/ql/plan/TezWork.java index e345215..c6ef829 100644 --- ql/src/java/org/apache/hadoop/hive/ql/plan/TezWork.java +++ ql/src/java/org/apache/hadoop/hive/ql/plan/TezWork.java @@ -82,7 +82,11 @@ public static boolean isCustomInputType(VertexType vertex) { public TezWork(String queryId, Configuration conf) { this.dagId = queryId + ":" + (++counter); - this.queryName = (conf != null) ? DagUtils.getUserSpecifiedDagName(conf) : null; + String queryName = (conf != null) ? DagUtils.getUserSpecifiedDagName(conf) : null; + if (queryName == null) { + queryName = this.dagId; + } + this.queryName = queryName; } @Explain(displayName = "DagName")