Hadoop Compression error #767

package org.xerial.snappy;

import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.RandomUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.compress.CompressionInputStream;
import org.apache.hadoop.io.compress.SnappyCodec;
import org.junit.Assert;
import org.junit.Test;

import java.io.FileOutputStream;
import java.nio.file.Files;
import java.nio.file.Path;

public class HadoopTest {
    
    @Test
    public void test() throws Exception{
        SnappyCodec hadoopCodec = new SnappyCodec();
        hadoopCodec.setConf(new Configuration());
        RandomUtils rnd = RandomUtils.insecure();
        
        for(int i=0; i < 99_000; i++){
            int size = rnd.randomInt(5_120, 512_000); // 5kb to 500kb
            byte[] input = rnd.randomBytes(size);
            
            Path tmp = Files.createTempFile("test", "test");
            FileOutputStream fileOutputStream = new FileOutputStream(tmp.toFile());
            SnappyHadoopCompatibleOutputStream snappyOutput = new SnappyHadoopCompatibleOutputStream(fileOutputStream);
            snappyOutput.write(input);
            snappyOutput.flush();
            
            
            CompressionInputStream snappyInput = hadoopCodec.createInputStream(Files.newInputStream(tmp));
            byte[] output = new byte[size];
            IOUtils.read(snappyInput, output);
            
            
            Assert.assertArrayEquals(input,output);
            Files.deleteIfExists(tmp);
        }
    }
}

private boolean hasSufficientOutputBufferFor(int inputSize)
    {
        int maxCompressedSize = Snappy.maxCompressedLength(inputSize);
        // I changed the magic number of 4 to 7
        return maxCompressedSize < outputBuffer.length - outputCursor - 7;
    }