You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2015/05/28 20:14:10 UTC
hive git commit: HIVE-10829: ATS hook fails for explainTask
(Pengcheng Xiong via Gunther Hagleitner)
Repository: hive
Updated Branches:
refs/heads/master 49cc02873 -> 49be24683
HIVE-10829: ATS hook fails for explainTask (Pengcheng Xiong via Gunther Hagleitner)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/49be2468
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/49be2468
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/49be2468
Branch: refs/heads/master
Commit: 49be24683980a32eeb59c44a93b537156b33b38c
Parents: 49cc028
Author: Gunther Hagleitner <gu...@apache.org>
Authored: Thu May 28 11:13:53 2015 -0700
Committer: Gunther Hagleitner <gu...@apache.org>
Committed: Thu May 28 11:13:53 2015 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/49be2468/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java
index 835015f..ada79bd 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java
@@ -586,7 +586,7 @@ public class ExplainTask extends Task<ExplainWork> implements Serializable {
if (note instanceof Explain) {
Explain xpl_note = (Explain) note;
boolean invokeFlag = false;
- if (this.work.isUserLevelExplain()) {
+ if (this.work != null && this.work.isUserLevelExplain()) {
invokeFlag = Level.USER.in(xpl_note.explainLevels());
} else {
if (extended) {
@@ -618,7 +618,7 @@ public class ExplainTask extends Task<ExplainWork> implements Serializable {
String appender = isLogical ? " (" + operator.getOperatorId() + ")" : "";
JSONObject jsonOut = outputPlan(operator.getConf(), out, extended,
jsonOutput, jsonOutput ? 0 : indent, appender);
- if (this.work.isUserLevelExplain()) {
+ if (this.work != null && this.work.isUserLevelExplain()) {
if (jsonOut != null && jsonOut.length() > 0) {
((JSONObject) jsonOut.get(JSONObject.getNames(jsonOut)[0])).put("OperatorId:",
operator.getOperatorId());
@@ -659,7 +659,7 @@ public class ExplainTask extends Task<ExplainWork> implements Serializable {
if (note instanceof Explain) {
Explain xpl_note = (Explain) note;
boolean invokeFlag = false;
- if (this.work.isUserLevelExplain()) {
+ if (this.work != null && this.work.isUserLevelExplain()) {
invokeFlag = Level.USER.in(xpl_note.explainLevels());
} else {
if (extended) {