diff --git hplsql/src/main/java/org/apache/hive/hplsql/Select.java hplsql/src/main/java/org/apache/hive/hplsql/Select.java index 589e984..403810c 100644 --- hplsql/src/main/java/org/apache/hive/hplsql/Select.java +++ hplsql/src/main/java/org/apache/hive/hplsql/Select.java @@ -147,10 +147,10 @@ else if (ctx.parent instanceof HplsqlParser.StmtContext) { } catch (SQLException e) { exec.signal(query); - exec.closeQuery(query, exec.conf.defaultConnection); + exec.closeQuery(query, conn); return 1; } - exec.closeQuery(query, exec.conf.defaultConnection); + exec.closeQuery(query, conn); return 0; } diff --git hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java index 17d2195..df656c0 100644 --- hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java +++ hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java @@ -793,7 +793,7 @@ else if (type == Conn.Type.HIVE && conf.insertValues == Conf.InsertValues.SELECT return 1; } exec.setSqlSuccess(); - exec.closeQuery(query, exec.conf.defaultConnection); + exec.closeQuery(query, conn); return 0; }