diff --git service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java index 976a1ef..bcedda2 100644 --- service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java +++ service/src/java/org/apache/hive/service/cli/operation/SQLOperation.java @@ -172,7 +172,7 @@ public RowSet getNextRowSet(FetchOrientation orientation, long maxRows) throws H ObjectInspector fieldOI; for (String rowString : rows) { - rowObj = serde.deserialize(new BytesWritable(rowString.getBytes())); + rowObj = serde.deserialize(new BytesWritable(rowString.getBytes("UTF-8"))); for (int i = 0; i < fieldRefs.size(); i++) { StructField fieldRef = fieldRefs.get(i); fieldOI = fieldRef.getFieldObjectInspector();