hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

load data sometimes coredump

Browse Source
This commit is contained in:
hnwyllmm
2024-02-08 05:05:51 +00:00
committed by ob-robot
parent 3582dcb33b
commit c581715dbb
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/cmd/ob_load_data_file_reader.cpp
View File

@ -42,6 +42,8 @@ ObFileReadParam::ObFileReadParam()
int ObFileReader::open(const ObFileReadParam &param, ObIAllocator &allocator, ObFileReader *& file_reader) int ObFileReader::open(const ObFileReadParam &param, ObIAllocator &allocator, ObFileReader *& file_reader)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
file_reader = nullptr;
if (param.file_location_ == ObLoadFileLocation::SERVER_DISK) { if (param.file_location_ == ObLoadFileLocation::SERVER_DISK) {
ObRandomFileReader *tmp_reader = OB_NEWx(ObRandomFileReader, &allocator, allocator); ObRandomFileReader *tmp_reader = OB_NEWx(ObRandomFileReader, &allocator, allocator);
if (OB_ISNULL(tmp_reader)) { if (OB_ISNULL(tmp_reader)) {

2
src/sql/engine/cmd/ob_load_data_impl.h
View File

@ -685,7 +685,7 @@ public:
InsertTask, InsertTask,
}; };
struct ToolBox { struct ToolBox {
ToolBox() : expr_buffer(nullptr) {} ToolBox() : file_reader(nullptr), job_status(nullptr), expr_buffer(nullptr) {}
int init(ObExecContext &ctx, ObLoadDataStmt &load_stmt); int init(ObExecContext &ctx, ObLoadDataStmt &load_stmt);
int build_calc_partid_expr(ObExecContext &ctx, int build_calc_partid_expr(ObExecContext &ctx,
ObLoadDataStmt &load_stmt, ObLoadDataStmt &load_stmt,