You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ss...@apache.org on 2016/01/25 00:36:54 UTC

[2/8] hive git commit: HIVE-12447. Fix LlapTaskReporter post TEZ-808 changes. (Siddharth Seth, reviewed by Sergey Shelukhin) (cherry picked from commit 9deed11a655f8ae5c308c6389025fd38983e0f8e)

HIVE-12447. Fix LlapTaskReporter post TEZ-808 changes. (Siddharth Seth, reviewed by Sergey Shelukhin)
(cherry picked from commit 9deed11a655f8ae5c308c6389025fd38983e0f8e)


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

Branch: refs/heads/branch-2.0
Commit: 2b817e1efb0a92b4efa72e4dbca7ea92a5173375
Parents: 76dcbff
Author: Siddharth Seth <ss...@apache.org>
Authored: Sun Jan 24 15:20:38 2016 -0800
Committer: Siddharth Seth <ss...@apache.org>
Committed: Sun Jan 24 15:29:55 2016 -0800

----------------------------------------------------------------------
 .../apache/hadoop/hive/llap/daemon/impl/LlapTaskReporter.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/2b817e1e/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapTaskReporter.java
----------------------------------------------------------------------
diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapTaskReporter.java b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapTaskReporter.java
index fc66254..bb9f341 100644
--- a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapTaskReporter.java
+++ b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapTaskReporter.java
@@ -350,13 +350,15 @@ public class LlapTaskReporter implements TaskReporterInterface {
       float progress = 0;
       if (task.hasInitialized()) {
         progress = task.getProgress();
+        // TODO HIVE-12449. Make use of progress notifications once Hive starts sending them out.
+        // progressNotified = task.getAndClearProgressNotification();
         if (sendCounters) {
           // send these potentially large objects at longer intervals to avoid overloading the AM
           counters = task.getCounters();
           stats = task.getTaskStatistics();
         }
       }
-      return new TaskStatusUpdateEvent(counters, progress, stats);
+      return new TaskStatusUpdateEvent(counters, progress, stats, true);
     }
 
     /**