diff --git a/service/src/java/org/apache/hive/service/cli/operation/OperationManager.java b/service/src/java/org/apache/hive/service/cli/operation/OperationManager.java index 2f18231..c26a611 100644 --- a/service/src/java/org/apache/hive/service/cli/operation/OperationManager.java +++ b/service/src/java/org/apache/hive/service/cli/operation/OperationManager.java @@ -200,6 +200,7 @@ private Operation getOperationInternal(OperationHandle operationHandle) { } private void addOperation(Operation operation) { + LOG.info("Adding operation: " + operation.getHandle()); handleToOperation.put(operation.getHandle(), operation); if (operation instanceof SQLOperation) { synchronized (webuiLock) { @@ -267,9 +268,10 @@ public void cancelOperation(OperationHandle opHandle) throws HiveSQLException { } public void closeOperation(OperationHandle opHandle) throws HiveSQLException { + LOG.info("Closing operation: " + opHandle); Operation operation = removeOperation(opHandle); if (operation == null) { - throw new HiveSQLException("Operation does not exist!"); + throw new HiveSQLException("Operation does not exist: " + opHandle); } Metrics metrics = MetricsFactory.getInstance(); if (metrics != null) { diff --git a/service/src/java/org/apache/hive/service/cli/session/SessionManager.java b/service/src/java/org/apache/hive/service/cli/session/SessionManager.java index ad8678e..4f5a852 100644 --- a/service/src/java/org/apache/hive/service/cli/session/SessionManager.java +++ b/service/src/java/org/apache/hive/service/cli/session/SessionManager.java @@ -357,7 +357,7 @@ public HiveSession createSession(SessionHandle sessionHandle, TProtocolVersion p public void closeSession(SessionHandle sessionHandle) throws HiveSQLException { HiveSession session = handleToSession.remove(sessionHandle); if (session == null) { - throw new HiveSQLException("Session does not exist!"); + throw new HiveSQLException("Session does not exist: " + sessionHandle); } try { session.close(); diff --git a/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java b/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java index 0c1114a..0dd56cb 100644 --- a/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java +++ b/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java @@ -320,7 +320,7 @@ public TOpenSessionResp OpenSession(TOpenSessionReq req) throws TException { if (context != null) { context.setSessionHandle(sessionHandle); } - LOG.info("Opened a session, current sessions: " + sessionCount.incrementAndGet()); + LOG.info("Opened a session " + sessionHandle + ", current sessions: " + sessionCount.incrementAndGet()); } catch (Exception e) { LOG.warn("Error opening session: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); @@ -466,7 +466,7 @@ public TCloseSessionResp CloseSession(TCloseSessionReq req) throws TException { try { SessionHandle sessionHandle = new SessionHandle(req.getSessionHandle()); cliService.closeSession(sessionHandle); - LOG.info("Closed a session, current sessions: " + sessionCount.decrementAndGet()); + LOG.info("Closed a session " + sessionHandle + ", current sessions: " + sessionCount.decrementAndGet()); resp.setStatus(OK_STATUS); ThriftCLIServerContext context = (ThriftCLIServerContext)currentServerContext.get();