MRUNIT-197 - Problems using Avro with MRUnit (Nicolas Dalsass via Brock)
authorBrock Noland <brock@apache.org>
Mon, 15 Dec 2014 22:19:48 +0000 (14:19 -0800)
committerBrock Noland <brock@apache.org>
Mon, 15 Dec 2014 22:19:48 +0000 (14:19 -0800)
src/main/java/org/apache/hadoop/mrunit/internal/io/Serialization.java

index c3d2842..a720bcc 100644 (file)
@@ -78,6 +78,7 @@ public class Serialization {
       final DataOutputBuffer outputBuffer = new DataOutputBuffer();
       serializer.open(outputBuffer);
       serializer.serialize(orig);
+      serializer.close();
       final DataInputBuffer inputBuffer = new DataInputBuffer();
       inputBuffer.reset(outputBuffer.getData(), outputBuffer.getLength());
       deserializer.open(inputBuffer);