diff --git a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcRecordReader.java b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcRecordReader.java index a3248b4..ce2871c 100644 --- a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcRecordReader.java +++ b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcRecordReader.java @@ -82,8 +82,7 @@ public boolean next(LongWritable key, MapWritable value) throws IOException { } } catch (Exception e) { - LOGGER.error("An error occurred while reading the next record from DB.", e); - return false; + throw new IOException(e); } }