LRR_kv_while_fix.java

while (getFilePosition() <= end || in.needAdditionalRecordAfterSplit()) {
  try {
    if (pos == 0) {
      newSize = skipUtfByteOrderMark();
    } else {
      newSize = in.readLine(value, maxLineLength, maxBytesToConsume(pos));
      pos += newSize;
    }

    if ((newSize == 0) || (newSize < maxLineLength)) {
      break;
    }

    // line too long. try again
    LOG.info("Skipped line of size " + newSize + " at pos " + 
             (pos - newSize));
  } catch(IOException e) {
    fileBroken = true;
    LOG.warn("Problem reading file " + this.splitName + " - " + e.getMessage());
  }
}