diff --git service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java index 2eaab4a..c8a69b9 100644 --- service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java +++ service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java @@ -462,7 +462,7 @@ private SerDe getSerDe() throws SQLException { * @return new configuration * @throws HiveSQLException */ - private HiveConf getConfigForOperation() throws HiveSQLException { + public HiveConf getConfigForOperation() throws HiveSQLException { HiveConf sqlOperationConf = getParentSession().getHiveConf(); if (!confOverlay.isEmpty() || shouldRunAsync()) { // clone the partent session config for this query diff --git service/src/resources/hive-webapps/hiveserver2/hiveserver2.jsp service/src/resources/hive-webapps/hiveserver2/hiveserver2.jsp index 0b437dd..a91b008 100644 --- service/src/resources/hive-webapps/hiveserver2/hiveserver2.jsp +++ service/src/resources/hive-webapps/hiveserver2/hiveserver2.jsp @@ -19,6 +19,8 @@ --%> <%@ page contentType="text/html;charset=UTF-8" import="org.apache.hadoop.conf.Configuration" + import="org.apache.hadoop.hive.conf.HiveConf" + import="org.apache.hadoop.hive.conf.HiveConf.ConfVars" import="org.apache.hive.common.util.HiveVersionInfo" import="org.apache.hive.service.cli.operation.Operation" import="org.apache.hive.service.cli.operation.SQLOperation" @@ -126,6 +128,7 @@ for (HiveSession hiveSession: hiveSessions) { User Name Query + Execution Engine State Elapsed Time (s) @@ -140,6 +143,7 @@ for (Operation operation: operations) { <%= query.getParentSession().getUserName() %> <%= query.getQueryStr() %> + <%= query.getConfigForOperation().getVar(ConfVars.HIVE_EXECUTION_ENGINE) %> <%= query.getStatus().getState() %> <%= (currentTime - query.getLastAccessTime())/1000 %> @@ -148,7 +152,7 @@ for (Operation operation: operations) { } %> - Total number of queries: <%= queries %> + Total number of queries: <%= queries %>