Index: service/src/java/org/apache/hadoop/hive/service/HiveServer.java =================================================================== --- service/src/java/org/apache/hadoop/hive/service/HiveServer.java (revision 1387251) +++ service/src/java/org/apache/hadoop/hive/service/HiveServer.java (working copy) @@ -179,6 +179,12 @@ String SQLState = null; try { + // Close the existing driver object (CommandProcessor) before creating + // the new driver (CommandProcessor) object to clean-up the resources + if (driver != null) { + driver.close(); + driver = null; + } CommandProcessor proc = CommandProcessorFactory.get(tokens[0]); if (proc != null) { if (proc instanceof Driver) {