diff --git a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe.java b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe. java index 04927a8bdc..b70206528c 100644 --- a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe.java +++ b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe.java @@ -135,6 +135,7 @@ public void initialize(Configuration conf, Properties properties) throws SerDeEx ObjectInspectorFactory.getStandardStructObjectInspector(Arrays.asList(hiveColumnNames), fieldInspectors); row = new ArrayList<>(hiveColumnNames.length); + hiveColumnNames = Arrays.asList(hiveColumnNames).stream().map(String::toLowerCase).toArray(String[]::new); } } catch (Exception e) { @@ -228,7 +229,6 @@ public Object deserialize(Writable blob) throws SerDeException { columnKey.set(hiveColumnNames[i]); Writable value = input.get(columnKey); Object rowVal; - if(value instanceof NullWritable) { rowVal = null; } else { 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 cd7cd4f7b2..c14fdfa68c 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 @@ -64,6 +64,7 @@ public JdbcRecordIterator(Connection conn, PreparedStatement ps, ResultSet rs, C } hiveColumnNames = fieldNamesProperty.trim().split(","); hiveColumnTypesList = TypeInfoUtils.getTypeInfosFromTypeString(fieldTypesProperty); + hiveColumnNames = Arrays.asList(hiveColumnNames).stream().map(String::toLowerCase).toArray(String[]::new); }