You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jc...@apache.org on 2019/10/29 22:57:35 UTC

[hive] branch master updated: HIVE-22357: Schema mismatch between the Hive table definition and the 'hive.sql.query' parameter (Rajkumar Singh via Jesus Camacho Rodriguez)

This is an automated email from the ASF dual-hosted git repository.

jcamacho pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 305e710  HIVE-22357: Schema mismatch between the Hive table definition and the 'hive.sql.query' parameter (Rajkumar Singh via Jesus Camacho Rodriguez)
305e710 is described below

commit 305e7100aadb72b5738e47682634fdb680bfd6bb
Author: Rajkumar Singh <ra...@apache.org>
AuthorDate: Tue Oct 29 15:57:18 2019 -0700

    HIVE-22357: Schema mismatch between the Hive table definition and the 'hive.sql.query' parameter (Rajkumar Singh via Jesus Camacho Rodriguez)
---
 .../java/org/apache/hive/storage/jdbc/dao/JdbcRecordIterator.java     | 4 ++++
 1 file changed, 4 insertions(+)

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 27538f7..dbc8453 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.Connection;
 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 class JdbcRecordIterator implements Iterator<Map<String, Object>> {
     }
     catch (Exception e) {
       LOGGER.warn("next() threw exception", e);
+      if (e instanceof SQLException){
+        throw new RuntimeException(e);
+      }
       return null;
     }
   }