@Test
public void testCopyFromHostExtraBytes() throws Exception {

  Fetcher<Text,Text> underTest = new FakeFetcher<Text,Text>(job, id, ss, mm,
      r, metrics, except, key, connection);
  String replyHash = SecureShuffleUtils.generateHash(encHash.getBytes(), key);
  when(connection.getResponseCode()).thenReturn(200);
  when(connection.getHeaderField(ShuffleHeader.HTTP_HEADER_NAME))
      .thenReturn(ShuffleHeader.DEFAULT_HTTP_HEADER_NAME);
  when(connection.getHeaderField(ShuffleHeader.HTTP_HEADER_VERSION))
      .thenReturn(ShuffleHeader.DEFAULT_HTTP_HEADER_VERSION);
  when(connection.getHeaderField(
      SecureShuffleUtils.HTTP_HEADER_REPLY_URL_HASH)).thenReturn(replyHash);
  ShuffleHeader header = new ShuffleHeader(map1ID.toString(), 14, 10, 1);
  ByteArrayOutputStream bout = new ByteArrayOutputStream();
  DataOutputStream dos = new DataOutputStream(bout);
  IFileOutputStream ios = new IFileOutputStream(dos);
  header.write(dos);
  ios.write("MAPDATA123".getBytes());
  ios.finish();
  ShuffleHeader header2 = new ShuffleHeader(map2ID.toString(), 14, 10, 1);
  IFileOutputStream ios2 = new IFileOutputStream(dos);
  header2.write(dos);
  ios2.write("MAPDATA456".getBytes());
  ios2.finish();
  ByteArrayInputStream in = new ByteArrayInputStream(bout.toByteArray());
  when(connection.getInputStream()).thenReturn(in);
  // 8 < 10 therefore there appear to be extra bytes in the IFileInputStream
  InMemoryMapOutput<Text,Text> mapOut = new InMemoryMapOutput<Text, Text>(
      job, map1ID, mm, 8, null, true );
  InMemoryMapOutput<Text,Text> mapOut2 = new InMemoryMapOutput<Text, Text>(
      job, map2ID, mm, 10, null, true );
  when(mm.reserve(eq(map1ID), anyLong(), anyInt())).thenReturn(mapOut);
  when(mm.reserve(eq(map2ID), anyLong(), anyInt())).thenReturn(mapOut2);
  underTest.copyFromHost(host);
  verify(allErrs).increment(1);
  verify(ss).copyFailed(map1ID, host, true, false);
  verify(ss, never()).copyFailed(map2ID, host, true, false);
  verify(ss).putBackKnownMapOutput(any(MapHost.class), eq(map1ID));
  verify(ss).putBackKnownMapOutput(any(MapHost.class), eq(map2ID));
}