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 857e627..9df110e 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 @@ -210,7 +210,7 @@ public TExecuteStatementResp ExecuteStatement(TExecuteStatementReq req) throws T resp.setOperationHandle(operationHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error fetching results: ", e); + LOG.warn("Error executing statement: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -224,7 +224,7 @@ public TGetTypeInfoResp GetTypeInfo(TGetTypeInfoReq req) throws TException { resp.setOperationHandle(operationHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error executing statement: ", e); + LOG.warn("Error getting type info: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -238,7 +238,7 @@ public TGetCatalogsResp GetCatalogs(TGetCatalogsReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting type info: ", e); + LOG.warn("Error getting catalogs: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -253,7 +253,7 @@ public TGetSchemasResp GetSchemas(TGetSchemasReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting catalogs: ", e); + LOG.warn("Error getting schemas: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -269,7 +269,7 @@ public TGetTablesResp GetTables(TGetTablesReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting schemas: ", e); + LOG.warn("Error getting tables: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -283,7 +283,7 @@ public TGetTableTypesResp GetTableTypes(TGetTableTypesReq req) throws TException resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting tables: ", e); + LOG.warn("Error getting table types: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -302,7 +302,7 @@ public TGetColumnsResp GetColumns(TGetColumnsReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting table types: ", e); + LOG.warn("Error getting columns: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -318,7 +318,7 @@ public TGetFunctionsResp GetFunctions(TGetFunctionsReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting columns: ", e); + LOG.warn("Error getting functions: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -332,7 +332,7 @@ public TGetOperationStatusResp GetOperationStatus(TGetOperationStatusReq req) th resp.setOperationState(operationState.toTOperationState()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting functions: ", e); + LOG.warn("Error getting operation status: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -345,7 +345,7 @@ public TCancelOperationResp CancelOperation(TCancelOperationReq req) throws TExc cliService.cancelOperation(new OperationHandle(req.getOperationHandle())); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting operation status: ", e); + LOG.warn("Error cancelling operation: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -358,7 +358,7 @@ public TCloseOperationResp CloseOperation(TCloseOperationReq req) throws TExcept cliService.closeOperation(new OperationHandle(req.getOperationHandle())); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error canceling operation: ", e); + LOG.warn("Error closing operation: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -373,7 +373,7 @@ public TGetResultSetMetadataResp GetResultSetMetadata(TGetResultSetMetadataReq r resp.setSchema(schema.toTTableSchema()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error closing operation: ", e); + LOG.warn("Error getting result set metadata: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -391,7 +391,7 @@ public TFetchResultsResp FetchResults(TFetchResultsReq req) throws TException { resp.setHasMoreRows(false); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting result set metadata: ", e); + LOG.warn("Error fetching results: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp;