Index: ql/src/java/org/apache/hadoop/hive/ql/exec/TextRecordReader.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/TextRecordReader.java (revision 4486) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/TextRecordReader.java (working copy) @@ -33,7 +33,9 @@ private LineReader lineReader; private InputStream in; private Text row; - + static final int MAX_LINE_LENGTH = 1000; + static final int MAX_LINE_BYTES = 1000; + public void initialize(InputStream in, Configuration conf) throws IOException { lineReader = new LineReader(in, conf); this.in = in; @@ -47,8 +49,7 @@ public int next(Writable row) throws IOException { if (lineReader == null) return -1; - - return lineReader.readLine((Text)row); + return lineReader.readLine((Text)row, MAX_LINE_LENGTH, MAX_LINE_BYTES); } public void close() throws IOException {