diff --git ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java index 7e80c2d..6b13006 100644 --- ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java +++ ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java @@ -286,6 +286,9 @@ public class HiveHistory { String key = ent.getKey(); String val = ent.getValue(); if(val != null) { + // Get rid of windows style line endings first if any + val = val.replace("\r\n", " "); + // Get rid of unix style line endings later val = val.replace('\n', ' '); } sb.append(key + "=\"" + val + "\"");