This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch dev-1.0.1 in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit fceff7f98b1e12ccbc9c3b319d5543d3e9a95e29 Author: Pxl <[email protected]> AuthorDate: Tue May 31 19:20:22 2022 +0800 [bugfix]fix TableFunctionNode memory leak (#9853) --- be/src/exec/table_function_node.cpp | 1 + be/src/util/block_compression.cpp | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/be/src/exec/table_function_node.cpp b/be/src/exec/table_function_node.cpp index 1a06c0cb30..c2ed1f44a3 100644 --- a/be/src/exec/table_function_node.cpp +++ b/be/src/exec/table_function_node.cpp @@ -359,6 +359,7 @@ Status TableFunctionNode::close(RuntimeState* state) { } RETURN_IF_ERROR(exec_debug_action(TExecNodePhase::CLOSE)); Expr::close(_fn_ctxs, state); + vectorized::VExpr::close(_vfn_ctxs, state); if (_num_rows_filtered_counter != nullptr) { COUNTER_SET(_num_rows_filtered_counter, static_cast<int64_t>(_num_rows_filtered)); diff --git a/be/src/util/block_compression.cpp b/be/src/util/block_compression.cpp index 51f485f348..01c3734948 100644 --- a/be/src/util/block_compression.cpp +++ b/be/src/util/block_compression.cpp @@ -418,7 +418,7 @@ public: // follow ZSTD official example // https://github.com/facebook/zstd/blob/dev/examples/streaming_compression.c - Status compress(const std::vector<Slice>& inputs, Slice* output) const { + Status compress(const std::vector<Slice>& inputs, Slice* output) const override { if (!ctx_c) return Status::InvalidArgument("compression context NOT initialized"); // reset ctx to start new compress session @@ -479,7 +479,7 @@ public: // follow ZSTD official example // https://github.com/facebook/zstd/blob/dev/examples/streaming_decompression.c - Status decompress(const Slice& input, Slice* output) const { + Status decompress(const Slice& input, Slice* output) const override { if (!ctx_d) return Status::InvalidArgument("decompression context NOT initialized"); // reset ctx to start a new decompress session --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
