diff --git a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/dao/JdbcRecordIterator.java b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/dao/JdbcRecordIterator.java index 27538f77bf..dbc8453d31 100644 --- a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/dao/JdbcRecordIterator.java +++ b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/dao/JdbcRecordIterator.java @@ -29,6 +29,7 @@ import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLDataException; +import java.sql.SQLException; import java.util.HashMap; import java.util.Iterator; import java.util.List; @@ -143,6 +144,9 @@ public boolean hasNext() { } catch (Exception e) { LOGGER.warn("next() threw exception", e); + if (e instanceof SQLException){ + throw new RuntimeException(e); + } return null; } }