You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/18 18:52:32 UTC
[36/48] hive git commit: HIVE-20179: Some Tez jar-s are not on
classpath so HS2 keeps too long to start (Peter Vary,
reviewed by Zoltan Haindrich)
HIVE-20179: Some Tez jar-s are not on classpath so HS2 keeps too long to start (Peter Vary, reviewed by Zoltan Haindrich)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/4ab10801
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/4ab10801
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/4ab10801
Branch: refs/heads/master-txnstats
Commit: 4ab108013f764b5a04eead386f9f73e163f69e68
Parents: 85a3dd7
Author: Peter Vary <pv...@cloudera.com>
Authored: Tue Jul 17 09:55:02 2018 +0200
Committer: Peter Vary <pv...@cloudera.com>
Committed: Tue Jul 17 09:55:02 2018 +0200
----------------------------------------------------------------------
.../apache/hive/service/server/HiveServer2.java | 20 +++++++++++---------
1 file changed, 11 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/4ab10801/service/src/java/org/apache/hive/service/server/HiveServer2.java
----------------------------------------------------------------------
diff --git a/service/src/java/org/apache/hive/service/server/HiveServer2.java b/service/src/java/org/apache/hive/service/server/HiveServer2.java
index 2471883..432a341 100644
--- a/service/src/java/org/apache/hive/service/server/HiveServer2.java
+++ b/service/src/java/org/apache/hive/service/server/HiveServer2.java
@@ -738,16 +738,18 @@ public class HiveServer2 extends CompositeService {
}
}
- if (!activePassiveHA) {
- LOG.info("HS2 interactive HA not enabled. Starting tez sessions..");
- try {
- startOrReconnectTezSessions();
- } catch (Exception e) {
- LOG.error("Error starting Tez sessions: ", e);
- throw new ServiceException(e);
+ if (hiveConf.getVar(ConfVars.HIVE_EXECUTION_ENGINE).equals("tez")) {
+ if (!activePassiveHA) {
+ LOG.info("HS2 interactive HA not enabled. Starting tez sessions..");
+ try {
+ startOrReconnectTezSessions();
+ } catch (Exception e) {
+ LOG.error("Error starting Tez sessions: ", e);
+ throw new ServiceException(e);
+ }
+ } else {
+ LOG.info("HS2 interactive HA enabled. Tez sessions will be started/reconnected by the leader.");
}
- } else {
- LOG.info("HS2 interactive HA enabled. Tez sessions will be started/reconnected by the leader.");
}
}