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

Fix default values for ObLoadDataStat

Browse Source
This commit is contained in:
leftgeek
2023-07-11 06:24:22 +00:00
committed by ob-robot
parent aa1439cd12
commit 4aee898f21
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/sql/engine/cmd/ob_load_data_utils.h
View File

@ -310,7 +310,7 @@ struct ObLoadDataStat
ref_cnt_(0), ref_cnt_(0),
tenant_id_(0), tenant_id_(0),
job_id_(0), job_id_(0),
job_type_(), job_type_("normal"),
table_name_(), table_name_(),
file_path_(), file_path_(),
table_column_(0), table_column_(0),
@ -365,17 +365,17 @@ struct ObLoadDataStat
int64_t max_allowed_error_rows_; int64_t max_allowed_error_rows_;
int64_t detected_error_rows_; int64_t detected_error_rows_;
struct { struct {
volatile int64_t received_rows_; // received from client volatile int64_t received_rows_ = 0; // received from client
int64_t last_commit_segment_id_; int64_t last_commit_segment_id_ = 0;
common::ObString status_; // none / inited / loading / frozen / merging / commit / error / abort common::ObString status_ = "none"; // none / inited / loading / frozen / merging / commit / error / abort
common::ObString trans_status_; // none / inited / running / frozen / commit / error / abort common::ObString trans_status_ = "none"; // none / inited / running / frozen / commit / error / abort
} coordinator; } coordinator;
struct { struct {
volatile int64_t processed_rows_; volatile int64_t processed_rows_ = 0;
int64_t last_commit_segment_id_; int64_t last_commit_segment_id_ = 0;
common::ObString status_; common::ObString status_ = "none";
common::ObString trans_status_; common::ObString trans_status_ = "none";
} store; } store;
TO_STRING_KV(K(tenant_id_), K(job_id_), K(job_type_), TO_STRING_KV(K(tenant_id_), K(job_id_), K(job_type_),