> On Sept. 12, 2017, 6:56 p.m., Zhiyuan Yang wrote: > > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/GuaranteedTasksAllocator.java > > Lines 191 (patched) > > <https://reviews.apache.org/r/62091/diff/2/?file=1815854#file1815854line191> > > > > How would AM registry help in AM recovery? If that's not the case, this > > piece means any update during AM failure & recovery will fail the session, > > which make AM recovery in vain.
What do you mean by AM recovery? Reopening the session would produce a new session object in the pool. > On Sept. 12, 2017, 6:56 p.m., Zhiyuan Yang wrote: > > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/GuaranteedTasksAllocator.java > > Lines 201-215 (patched) > > <https://reviews.apache.org/r/62091/diff/2/?file=1815854#file1815854line201> > > > > You are really determined to knock out that field... This is gone now. > On Sept. 12, 2017, 6:56 p.m., Zhiyuan Yang wrote: > > service/src/java/org/apache/hive/service/server/HiveServer2.java > > Lines 169 (patched) > > <https://reviews.apache.org/r/62091/diff/2/?file=1815871#file1815871line170> > > > > Where is the code that really put this wm instance in use? Additional > > jira? It's used thru the global, see getInstance called from TezTask. I have a separate patch to get rid of some globals in HS2 that may make it more clear. - Sergey ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/62091/#review185018 ----------------------------------------------------------- On Sept. 5, 2017, 6:52 p.m., Sergey Shelukhin wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/62091/ > ----------------------------------------------------------- > > (Updated Sept. 5, 2017, 6:52 p.m.) > > > Review request for hive, Zhiyuan Yang, Gunther Hagleitner, and Siddharth Seth. > > > Repository: hive-git > > > Description > ------- > > see jira > > > Diffs > ----- > > common/src/java/org/apache/hadoop/hive/conf/HiveConf.java 6de07d2e76 > itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java > b3677322ca > > llap-client/src/java/org/apache/hadoop/hive/llap/tez/LlapProtocolClientProxy.java > b6501842e8 > llap-client/src/test/org/apache/hadoop/hive/llap/TestAsyncPbRpcProxy.java > 1c4f0e7a09 > llap-common/src/java/org/apache/hadoop/hive/llap/AsyncPbRpcProxy.java > 7726794fea > > llap-common/src/java/org/apache/hadoop/hive/llap/impl/LlapPluginProtocolClientImpl.java > 19e81e6fa5 > llap-common/src/java/org/apache/hadoop/hive/llap/impl/ProtobufProxy.java > fa99536bea > llap-common/src/protobuf/LlapPluginProtocol.proto 39349b119d > > llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java > cf8bd469dc > > llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/endpoint/LlapPluginServerImpl.java > f3c0d5213f > ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java 93a36c612d > > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/GuaranteedTasksAllocator.java > PRE-CREATION > > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/LlapPluginEndpointClient.java > PRE-CREATION > > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/LlapPluginEndpointClientImpl.java > PRE-CREATION > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/QueryAllocationManager.java > PRE-CREATION > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionPool.java > 4f58565a4c > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionPoolManager.java > 1f4705c083 > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionPoolSession.java > 005eeedc02 > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java > fe5c6a1e45 > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java f1f10286a3 > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WmTezSession.java > PRE-CREATION > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java > PRE-CREATION > > ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java > 9e2846ca6c > > ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/LlapClusterStateForCompile.java > 7a02a563e9 > ql/src/test/org/apache/hadoop/hive/ql/exec/tez/SampleTezSessionState.java > 973c0cc630 > > ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestGuaranteedTaskAllocator.java > PRE-CREATION > ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezSessionPool.java > d2b98c46ca > ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestWorkloadManager.java > PRE-CREATION > service/src/java/org/apache/hive/service/server/HiveServer2.java e5f449122b > > > Diff: https://reviews.apache.org/r/62091/diff/2/ > > > Testing > ------- > > > Thanks, > > Sergey Shelukhin > >
