diff --git service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java index 2938338..81a8347 100644 --- service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java +++ service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java @@ -320,7 +320,7 @@ public TOpenSessionResp OpenSession(TOpenSessionReq req) throws TException { context.setSessionHandle(sessionHandle); } } catch (Exception e) { - LOG.warn("Error opening session: ", e); + LOG.error("Error opening session: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -471,7 +471,7 @@ public TCloseSessionResp CloseSession(TCloseSessionReq req) throws TException { context.setSessionHandle(null); } } catch (Exception e) { - LOG.warn("Error closing session: ", e); + LOG.error("Error closing session: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -487,7 +487,7 @@ public TGetInfoResp GetInfo(TGetInfoReq req) throws TException { resp.setInfoValue(getInfoValue.toTGetInfoValue()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting info: ", e); + LOG.error("Error getting info: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -512,7 +512,7 @@ public TExecuteStatementResp ExecuteStatement(TExecuteStatementReq req) throws T // Note: it's rather important that this (and other methods) catch Exception, not Throwable; // in combination with HiveSessionProxy.invoke code, perhaps unintentionally, it used // to also catch all errors; and now it allows OOMs only to propagate. - LOG.warn("Error executing statement: ", e); + LOG.error("Error executing statement: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -526,7 +526,7 @@ public TGetTypeInfoResp GetTypeInfo(TGetTypeInfoReq req) throws TException { resp.setOperationHandle(operationHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting type info: ", e); + LOG.error("Error getting type info: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -540,7 +540,7 @@ public TGetCatalogsResp GetCatalogs(TGetCatalogsReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting catalogs: ", e); + LOG.error("Error getting catalogs: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -555,7 +555,7 @@ public TGetSchemasResp GetSchemas(TGetSchemasReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting schemas: ", e); + LOG.error("Error getting schemas: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -571,7 +571,7 @@ public TGetTablesResp GetTables(TGetTablesReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting tables: ", e); + LOG.error("Error getting tables: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -585,7 +585,7 @@ public TGetTableTypesResp GetTableTypes(TGetTableTypesReq req) throws TException resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting table types: ", e); + LOG.error("Error getting table types: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -604,7 +604,7 @@ public TGetColumnsResp GetColumns(TGetColumnsReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting columns: ", e); + LOG.error("Error getting columns: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -620,7 +620,7 @@ public TGetFunctionsResp GetFunctions(TGetFunctionsReq req) throws TException { resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting functions: ", e); + LOG.error("Error getting functions: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -646,7 +646,7 @@ public TGetOperationStatusResp GetOperationStatus(TGetOperationStatusReq req) th } resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting operation status: ", e); + LOG.error("Error getting operation status: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -659,7 +659,7 @@ public TCancelOperationResp CancelOperation(TCancelOperationReq req) throws TExc cliService.cancelOperation(new OperationHandle(req.getOperationHandle())); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error cancelling operation: ", e); + LOG.error("Error cancelling operation: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -672,7 +672,7 @@ public TCloseOperationResp CloseOperation(TCloseOperationReq req) throws TExcept cliService.closeOperation(new OperationHandle(req.getOperationHandle())); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error closing operation: ", e); + LOG.error("Error closing operation: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -687,7 +687,7 @@ public TGetResultSetMetadataResp GetResultSetMetadata(TGetResultSetMetadataReq r resp.setSchema(schema.toTTableSchema()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting result set metadata: ", e); + LOG.error("Error getting result set metadata: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -706,7 +706,7 @@ public TFetchResultsResp FetchResults(TFetchResultsReq req) throws TException { resp.setHasMoreRows(false); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error fetching results: ", e); + LOG.error("Error fetching results: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -723,7 +723,7 @@ public TGetPrimaryKeysResp GetPrimaryKeys(TGetPrimaryKeysReq req) resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting functions: ", e); + LOG.error("Error getting functions: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp; @@ -741,7 +741,7 @@ public TGetCrossReferenceResp GetCrossReference(TGetCrossReferenceReq req) resp.setOperationHandle(opHandle.toTOperationHandle()); resp.setStatus(OK_STATUS); } catch (Exception e) { - LOG.warn("Error getting functions: ", e); + LOG.error("Error getting functions: ", e); resp.setStatus(HiveSQLException.toTStatus(e)); } return resp;