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); } /**