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

shared hj + channel sync hang

Browse Source
This commit is contained in:
sdc
2024-05-07 14:23:14 +00:00
committed by ob-robot
parent a877c71ef8
commit 070583812e
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/sql/engine/px/ob_px_task_process.cpp
View File

@ -327,6 +327,10 @@ int ObPxTaskProcess::execute(ObOpSpec &root_spec)
ret = OB_SUCCESS == ret ? tmp_ret : ret;
LOG_WARN("failed to apply error code", K(ret), K(tmp_ret));
}
if (OB_SUCCESS != (tmp_ret = ObInterruptUtil::interrupt_tasks(arg_.get_sqc_handler()->get_sqc_init_arg().sqc_,
OB_GOT_SIGNAL_ABORTING))) {
LOG_WARN("interrupt_tasks failed", K(tmp_ret));
}
}
if (OB_SUCCESS != (close_ret = root->close())) {
LOG_WARN("fail close dfo op", K(ret), K(close_ret));
@ -495,13 +499,6 @@ int ObPxTaskProcess::do_process()
LOG_WARN("interrupt_qc failed", K(tmp_ret));
}
}
// Regardless of whether interrupt_qc succeeds or not,
// always execute interrupt_tasks to ensure other threads in the current sqc terminate more quickly,
// thereby improving overall efficiency.
if (OB_SUCCESS != (tmp_ret = ObInterruptUtil::interrupt_tasks(arg_.get_sqc_handler()->get_sqc_init_arg().sqc_,
OB_GOT_SIGNAL_ABORTING))) {
LOG_WARN("interrupt_tasks failed", K(tmp_ret));
}
}
}