You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jd...@apache.org on 2017/11/28 22:47:51 UTC

hive git commit: HIVE-18151: LLAP external client: Better error message propagation during submission failures (Jason Dere, reviewed by Sergey Shelukhin)

Repository: hive
Updated Branches:
  refs/heads/master 5add3a7ec -> 8d39a0887


HIVE-18151: LLAP external client: Better error message propagation during submission failures (Jason Dere, reviewed by Sergey Shelukhin)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/8d39a088
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8d39a088
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8d39a088

Branch: refs/heads/master
Commit: 8d39a0887618a3a4cb57b878095041a5db013177
Parents: 5add3a7
Author: Jason Dere <jd...@hortonworks.com>
Authored: Tue Nov 28 14:46:51 2017 -0800
Committer: Jason Dere <jd...@hortonworks.com>
Committed: Tue Nov 28 14:46:51 2017 -0800

----------------------------------------------------------------------
 .../src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/8d39a088/llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java
----------------------------------------------------------------------
diff --git a/llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java b/llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java
index 02f88c2..fc360d4 100644
--- a/llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java
+++ b/llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java
@@ -474,7 +474,7 @@ public class LlapBaseInputFormat<V extends WritableComparable<?>>
     public void submissionFailed(String fragmentId, Throwable throwable) {
       try {
         sendOrQueueEvent(ReaderEvent.errorEvent(
-            "Received submission failed event for fragment ID " + fragmentId));
+            "Received submission failed event for fragment ID " + fragmentId + ": " + throwable.toString()));
       } catch (Exception err) {
         LOG.error("Error during heartbeat responder:", err);
       }