diff --git jdbc/src/java/org/apache/hive/jdbc/HiveStatement.java jdbc/src/java/org/apache/hive/jdbc/HiveStatement.java index a0aea72..c385e2c 100644 --- jdbc/src/java/org/apache/hive/jdbc/HiveStatement.java +++ jdbc/src/java/org/apache/hive/jdbc/HiveStatement.java @@ -315,9 +315,11 @@ private void runAsyncOnServer(String sql) throws SQLException { isExecuteStatementFailed = false; } catch (SQLException eS) { isExecuteStatementFailed = true; + isLogBeingGenerated = false; throw eS; } catch (Exception ex) { isExecuteStatementFailed = true; + isLogBeingGenerated = false; throw new SQLException(ex.toString(), "08S01", ex); } } @@ -914,10 +916,6 @@ public boolean hasMoreLogs() { if (isQueryClosed) { throw new ClosedOrCancelledStatementException("Method getQueryLog() failed. The " + "statement has been closed or cancelled."); - } - if (isExecuteStatementFailed) { - throw new SQLException("Method getQueryLog() failed. Because the stmtHandle in " + - "HiveStatement is null and the statement execution might fail."); } else { return logs; }