diff --git jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveQueryResultSet.java jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveQueryResultSet.java index c80e862..235db61 100644 --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveQueryResultSet.java +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveQueryResultSet.java @@ -38,6 +38,7 @@ import org.apache.hadoop.hive.serde2.objectinspector.StructField; import org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector; import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorUtils.ObjectInspectorCopyOption; import org.apache.hadoop.hive.service.HiveInterface; +import org.apache.hadoop.hive.ql.exec.Utilities; import org.apache.hadoop.io.BytesWritable; /** @@ -102,6 +103,7 @@ public class HiveQueryResultSet extends HiveBaseResultSet { LOG.info("Column types: " + types); props.setProperty(Constants.LIST_COLUMN_TYPES, types); } + props.setProperty(Constants.FIELD_DELIM, Integer.toString(Utilities.tabCode)); serde.initialize(new Configuration(), props); } catch (Exception ex) {