[SPARK-2897][SPARK-2920]TorrentBroadcast does use the serializer class specified in the spark option "spark.serializer"

can we rewrite this as
```scala
val in: InputStream = {
  val istream = new ByteArrayInputStream(retByteArray)
  if (compress) compressionCodec.compressedInputStream(istream) else istream
}
```