From 5adb7334117d989ae1394982e00dcc5907cf4380 Mon Sep 17 00:00:00 2001
From: DB Tsai <dbtsai@dbtsai.com>
Date: Tue, 2 Dec 2025 14:11:57 -0800
Subject: [PATCH] use safeDecompressor()

---
 core/src/main/scala/org/apache/spark/io/CompressionCodec.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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)
   }