[CP] In distributed execution scenario, queue_time is less than zero.
This commit is contained in:
@ -125,7 +125,8 @@ int ObPxTaskProcess::process()
|
|||||||
{
|
{
|
||||||
int ret = OB_SUCCESS;
|
int ret = OB_SUCCESS;
|
||||||
|
|
||||||
process_timestamp_ = ObTimeUtility::current_time();
|
enqueue_timestamp_ = ObTimeUtility::current_time();
|
||||||
|
process_timestamp_ = enqueue_timestamp_;
|
||||||
|
|
||||||
ObExecRecord exec_record;
|
ObExecRecord exec_record;
|
||||||
ObExecTimestamp exec_timestamp;
|
ObExecTimestamp exec_timestamp;
|
||||||
@ -154,8 +155,7 @@ int ObPxTaskProcess::process()
|
|||||||
if (enable_sql_audit) {
|
if (enable_sql_audit) {
|
||||||
exec_record.record_start();
|
exec_record.record_start();
|
||||||
}
|
}
|
||||||
exec_start_timestamp_ = ObTimeUtility::current_time();
|
exec_start_timestamp_ = enqueue_timestamp_;
|
||||||
set_enqueue_timestamp(exec_start_timestamp_);
|
|
||||||
arg_.sqc_task_ptr_->task_monitor_info_.record_exec_time_begin();
|
arg_.sqc_task_ptr_->task_monitor_info_.record_exec_time_begin();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user