HIVE-12448. Change to tracking of dag status via dagIdentifier instead of dag name. (Siddharth Seth, reviewed by Sergey Shelukhin) (cherry picked from commit 16d495809382cf1db54ab26ff3a7ba5d57caa9b2)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/94e8761a Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/94e8761a Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/94e8761a Branch: refs/heads/branch-2.0 Commit: 94e8761a28ccd5aaac0fb31d92767111a94fb036 Parents: 2b817e1 Author: Siddharth Seth <ss...@apache.org> Authored: Sun Jan 24 15:21:58 2016 -0800 Committer: Siddharth Seth <ss...@apache.org> Committed: Sun Jan 24 15:30:01 2016 -0800 ---------------------------------------------------------------------- .../daemon/rpc/LlapDaemonProtocolProtos.java | 2079 ++++++++++++------ .../hadoop/hive/llap/daemon/HistoryLogger.java | 19 +- .../hive/llap/daemon/KilledTaskHandler.java | 3 +- .../hive/llap/daemon/QueryFailedHandler.java | 4 +- .../hive/llap/daemon/impl/AMReporter.java | 42 +- .../llap/daemon/impl/ContainerRunnerImpl.java | 47 +- .../hive/llap/daemon/impl/LlapDaemon.java | 4 +- .../hive/llap/daemon/impl/QueryIdentifier.java | 63 + .../hadoop/hive/llap/daemon/impl/QueryInfo.java | 14 +- .../hive/llap/daemon/impl/QueryTracker.java | 118 +- .../llap/daemon/impl/TaskRunnerCallable.java | 9 +- .../hadoop/hive/llap/tezplugins/Converters.java | 1 - .../llap/tezplugins/LlapTaskCommunicator.java | 50 +- .../tezplugins/helpers/SourceStateTracker.java | 22 +- .../src/protobuf/LlapDaemonProtocol.proto | 17 +- .../daemon/impl/TaskExecutorTestHelpers.java | 30 +- .../llap/daemon/impl/TestQueryIdentifier.java | 48 + 17 files changed, 1697 insertions(+), 873 deletions(-) ----------------------------------------------------------------------
