fix core

hubgeter · Nov 27, 2023 · df296cb · df296cb
1 parent 3f8ba47
commit df296cb
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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: