hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gunt...@apache.org
Subject hive git commit: HIVE-10829: ATS hook fails for explainTask (Pengcheng Xiong via Gunther Hagleitner)
Date Thu, 28 May 2015 18:14:10 GMT
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 <gunther@apache.org>
Authored: Thu May 28 11:13:53 2015 -0700
Committer: Gunther Hagleitner <gunther@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) {


Mime
View raw message