diff --git a/be/src/util/block_compression.cpp b/be/src/util/block_compression.cpp index 7afbafa9790a68..1c2a65b5337749 100644 --- a/be/src/util/block_compression.cpp +++ b/be/src/util/block_compression.cpp @@ -108,11 +108,13 @@ class Lz4BlockCompression : public BlockCompressionCodec { } Status compress(const Slice& input, faststring* output) override { - if (input.size > INT_MAX) { + if (input.size > LZ4_MAX_INPUT_SIZE) { return Status::InvalidArgument( - "LZ4 not support those case(input.size>INT_MAX), maybe you should change " - "fragment_transmission_compression_codec to snappy, size={}", - input.size); + "LZ4 not support those case(input.size>LZ4_MAX_INPUT_SIZE), maybe you should " + "change " + "fragment_transmission_compression_codec to snappy, input.size={}, " + "LZ4_MAX_INPUT_SIZE={}", + input.size, LZ4_MAX_INPUT_SIZE); } Context* context;