This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 591bdb56ec828fa6dbf03befaec0e1889443ec71
Author: Luwei <814383...@qq.com>
AuthorDate: Tue Aug 20 11:54:17 2024 +0800
[enhancement](compression) prints the specific exception when ZSTD compress
fails (#39433)
---
be/src/util/block_compression.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/util/block_compression.cpp
b/be/src/util/block_compression.cpp
index 439860909e8..e71a8901421 100644
--- a/be/src/util/block_compression.cpp
+++ b/be/src/util/block_compression.cpp
@@ -20,6 +20,8 @@
#include <gen_cpp/parquet_types.h>
#include <gen_cpp/segment_v2.pb.h>
#include <glog/logging.h>
+
+#include <exception>
// Only used on x86 or x86_64
#if defined(__x86_64__) || defined(_M_X64) || defined(i386) ||
defined(__i386__) || \
defined(__i386) || defined(_M_IX86)
@@ -951,6 +953,8 @@ public:
if (max_len <= MAX_COMPRESSION_BUFFER_SIZE_FOR_REUSE) {
output->assign_copy(reinterpret_cast<uint8_t*>(compressed_buf.data),
out_buf.pos);
}
+ } catch (std::exception e) {
+ return Status::InternalError("Fail to do ZSTD compress due to
exception {}", e.what());
} catch (...) {
// Do not set compress_failed to release context
DCHECK(!compress_failed);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
