hdfs文件流封装为压缩流一次读写128K

大家好，我又来了，具体问题：获取hadoop上的一个文件，由于需求，需要封装为zip流返回，但read时，虽然声明的数组是50M，但每次还是只读了131072字节(128K)；由于不耽误业务的使用，所以放在那没优化，但最近业务出问题了，在排查；所以想把这里优化下，具体代码如下：

val aa:String = "hdfs://127.0.0.1:9000/test/my_test.jar"
//调用封好的工具类，返回FSDataInputStream文件流
val inputStream:FSDataInputStream= HdfsUtil.getFSDataInputStream(aa)
val byteArrayOutputStream = new ByteArrayOutputStream()
//创建压缩流
val zos = new ZipOutputStream(byteArrayOutputStream)
val jarName = jarPath.substring(jarPath.lastIndexOf("/")+1)
val zipEntry:ZipEntry = new ZipEntry(jarName)
zos.putNextEntry(zipEntry)
var flag = true
var index = 0;
var i:Int = 0;
while(flag){
    //循环read Hdfs的文件流
    val byte:Array[Byte] =new Array[Byte](1024*1024);
    index = inputStream.read(byte,0,byte.length)
    //打印一下每次读取的字节数
    println("----------------------index------------------:"+index)
    if (index>0){
      i=i+1;
      //这个文件读取了多少次
      println("--------------i---------------:"+i)
      zos.write(byte,0,index)
    }else{
      flag = false
    }
}
zos.closeEntry()
zos.close()

//接下来都是无用代码，省略

读取过程如下：

按说260M的文件，一次读取50M，读取六次就够了；但现在结果是每次只read了128K，声明的byte数组长度没用；也追了追源码，确实找到了131072的由来；但本人才疏学浅，实在不知道调整哪里，望大家不吝赐教，多谢

追的源码在网站找了个博主的记录，我这里也就直接借用一下，curDataSlice的值就是131072，也尝试修改了hadoop配置文件中的和文件大小相关耳朵配置，但最终也没解决，

想要达到的效果：read时能按照我声明的byte数组大小读取字节（至少不能是现在每次读取128K）

顶一下，不要沉了啊！！！！