mTestStream.write(BufferUtils.getIncreasingByteArray(bytesToWrite + offset), offset,
bytesToWrite);
verifyIncreasingBytesWritten(offset, bytesToWrite);
}
@Test
<BUG>public void closeTest() throws Exception {
mTestStream.write(BufferUtils.getIncreasingByteArray((int) (BLOCK_LENGTH * 1.5)));</BUG>
mTestStream.close();
for (long streamIndex = 0; streamIndex < 2; streamIndex ++) {
Assert.assertFalse(mTachyonOutStreamMap.get(streamIndex).isCanceled());

mTestStream.write(BufferUtils.getIncreasingByteArray(bytesToWrite + offset), offset,
bytesToWrite);
verifyIncreasingBytesWritten(offset, bytesToWrite);
}
@Test
public void closeTest() throws Exception {
Mockito.when(mUnderFileSystem.rename(Mockito.anyString(), Mockito.anyString()))
.thenReturn(true);
mTestStream.write(BufferUtils.getIncreasingByteArray((int) (BLOCK_LENGTH * 1.5)));
mTestStream.close();
for (long streamIndex = 0; streamIndex < 2; streamIndex ++) {
Assert.assertFalse(mTachyonOutStreamMap.get(streamIndex).isCanceled());
