From 4d45724267234e11cc96918e812b338bd8d49509 Mon Sep 17 00:00:00 2001 From: hnwyllmm Date: Wed, 20 Dec 2023 11:52:46 +0000 Subject: [PATCH] load data sometimes coredump --- src/sql/engine/cmd/ob_load_data_file_reader.cpp | 2 ++ src/sql/engine/cmd/ob_load_data_impl.h | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/sql/engine/cmd/ob_load_data_file_reader.cpp b/src/sql/engine/cmd/ob_load_data_file_reader.cpp index dc572e17f8..90ea1da2c3 100644 --- a/src/sql/engine/cmd/ob_load_data_file_reader.cpp +++ b/src/sql/engine/cmd/ob_load_data_file_reader.cpp @@ -42,6 +42,8 @@ ObFileReadParam::ObFileReadParam() int ObFileReader::open(const ObFileReadParam ¶m, ObIAllocator &allocator, ObFileReader *& file_reader) { int ret = OB_SUCCESS; + file_reader = nullptr; + if (param.file_location_ == ObLoadFileLocation::SERVER_DISK) { ObRandomFileReader *tmp_reader = OB_NEWx(ObRandomFileReader, &allocator, allocator); if (OB_ISNULL(tmp_reader)) { diff --git a/src/sql/engine/cmd/ob_load_data_impl.h b/src/sql/engine/cmd/ob_load_data_impl.h index fcbc564603..43c65ae896 100644 --- a/src/sql/engine/cmd/ob_load_data_impl.h +++ b/src/sql/engine/cmd/ob_load_data_impl.h @@ -685,7 +685,7 @@ public: InsertTask, }; struct ToolBox { - ToolBox() : expr_buffer(nullptr) {} + ToolBox() : file_reader(nullptr), job_status(nullptr), expr_buffer(nullptr) {} int init(ObExecContext &ctx, ObLoadDataStmt &load_stmt); int build_calc_partid_expr(ObExecContext &ctx, ObLoadDataStmt &load_stmt,