This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 29088ebaeda [enhancement](compression) prints the specific exception
when ZSTD compress fails (#39433) (#39978)
29088ebaeda is described below
commit 29088ebaeda15681deca5659ce9db15e650f610c
Author: Luwei <[email protected]>
AuthorDate: Tue Aug 27 20:07:15 2024 +0800
[enhancement](compression) prints the specific exception when ZSTD compress
fails (#39433) (#39978)
cherry-pick #39433 to branch-2.1
---
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 ccc7cc1e95d..10f975451d3 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)
@@ -895,6 +897,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: [email protected]
For additional commands, e-mail: [email protected]
