diff --git a/core/src/main/scala/org/apache/spark/io/CompressionCodec.scala b/core/src/main/scala/org/apache/spark/io/CompressionCodec.scala
index b81e46667323..86bb20a6708b 100644
--- a/core/src/main/scala/org/apache/spark/io/CompressionCodec.scala
+++ b/core/src/main/scala/org/apache/spark/io/CompressionCodec.scala
@@ -155,7 +155,7 @@ class LZ4CompressionCodec(conf: SparkConf) extends CompressionCodec {
     val disableConcatenationOfByteStream = false
     new LZ4BlockInputStream(
       s,
-      lz4Factory.fastDecompressor(),
+      lz4Factory.safeDecompressor(),
       xxHashFactory.newStreamingHash32(defaultSeed).asChecksum,
       disableConcatenationOfByteStream)
   }