diff --git a/deps/oblib/src/lib/container/ob_mask_set2.h b/deps/oblib/src/lib/container/ob_mask_set2.h index 6296488058..c1bb8a1a01 100644 --- a/deps/oblib/src/lib/container/ob_mask_set2.h +++ b/deps/oblib/src/lib/container/ob_mask_set2.h @@ -43,9 +43,9 @@ public: { is_inited_ = false; array_ = NULL; - bitset_.reuse(); - } - void clear() + bitset_.reuse(); + } + void clear() { bitset_.reuse(); } @@ -123,9 +123,9 @@ public: is_new_mask = tmp_new_mask; } } - } - return ret; - } + } + return ret; + } bool is_all_mask() const { bool bool_ret = false; diff --git a/src/sql/engine/ob_physical_plan.cpp b/src/sql/engine/ob_physical_plan.cpp index 6053f17b3c..a4f64fbea2 100644 --- a/src/sql/engine/ob_physical_plan.cpp +++ b/src/sql/engine/ob_physical_plan.cpp @@ -491,6 +491,15 @@ void ObPhysicalPlan::update_plan_stat(const ObAuditRecordData &record, } else { ATOMIC_INC(&(stat_.hit_count_)); } + if (ATOMIC_LOAD(&stat_.is_evolution_)) { //for spm + ATOMIC_INC(&(stat_.evolution_stat_.executions_)); + // ATOMIC_AAF(&(stat_.evolution_stat_.cpu_time_), + // record.get_elapsed_time() - record.exec_record_.wait_time_end_ + // - (record.exec_timestamp_.run_ts_ - record.exec_timestamp_.receive_ts_)); + ATOMIC_AAF(&(stat_.evolution_stat_.cpu_time_), record.exec_timestamp_.executor_t_); + ATOMIC_AAF(&(stat_.evolution_stat_.elapsed_time_), record.get_elapsed_time()); + ATOMIC_STORE(&(stat_.evolution_stat_.last_exec_ts_), record.exec_timestamp_.executor_end_ts_); + } } else { // long route stat begin execute_count = ATOMIC_AAF(&stat_.execute_times_, 1); ATOMIC_AAF(&(stat_.total_process_time_), record.get_process_time());