Fixed bug in charset decoding logic.

VonRosenchild · Jul 2, 2012 · 8f14b18 · 8f14b18
1 parent c946ad9
commit 8f14b18
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pact/pact-common/src/main/java/eu/stratosphere/pact/common/io/TextInputFormat.java b/pact/pact-common/src/main/java/eu/stratosphere/pact/common/io/TextInputFormat.java
@@ -93,8 +93,9 @@ public boolean readRecord(PactRecord target, byte[] bytes, int offset, int numBy
  byteWrapper = ByteBuffer.wrap(bytes, 0, bytes.length);
  this.byteWrapper = byteWrapper;
  }
+ byteWrapper.clear();
  byteWrapper.position(offset);
- byteWrapper.limit(numBytes);
+ byteWrapper.limit(offset + numBytes);
 
  try {
  CharBuffer result = this.decoder.decode(byteWrapper);