From df296cbf159af969602397ec5465c237894baec8 Mon Sep 17 00:00:00 2001
From: changyuwei <2017501503@qq.com>
Date: Mon, 27 Nov 2023 17:11:20 +0800
Subject: [PATCH] fix core

---
 be/src/util/block_compression.cpp | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/be/src/util/block_compression.cpp b/be/src/util/block_compression.cpp
index 3cdeec54e009f5..45c1c26cd32d3b 100644
--- a/be/src/util/block_compression.cpp
+++ b/be/src/util/block_compression.cpp
@@ -202,7 +202,9 @@ class HadoopLz4BlockCompression : public Lz4BlockCompression {
                                             (uint8_t*)output->data, output->size, &decompressed_len,
                                             &stream_end, &more_input_bytes, &more_output_bytes);
         //try decompress use hadoopLz4 ,if failed fall back lz4.
-        return (st != Status::OK()) ? Lz4BlockCompression::decompress(input, output) : Status::OK();
+        return (st != Status::OK() || stream_end != true)
+                       ? Lz4BlockCompression::decompress(input, output)
+                       : Status::OK();
     }
 
 private: