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 80a615d..d94bbc9 100644 --- service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java +++ service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java @@ -264,7 +264,11 @@ private void runQuery() throws HiveSQLException { throw e; } } catch (Throwable e) { - setState(OperationState.ERROR); + try { + setState(OperationState.ERROR); + } catch (Exception ignore) { + LOG.warn("Failed to change state to ERROR", ignore); + } throw new HiveSQLException("Error running query: " + e.toString(), e); } setState(OperationState.FINISHED);