-
Notifications
You must be signed in to change notification settings - Fork 3.4k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[opt](query cancel) cancel query if it has pipeline task leakage #39223 #39537
[opt](query cancel) cancel query if it has pipeline task leakage #39223 #39537
Conversation
Thank you for your contribution to Apache Doris. Since 2024-03-18, the Document has been moved to doris-website. |
fb9c06c
to
c78fc0d
Compare
run buildall |
run buildall |
run buildall |
run buildall |
run buildall |
@@ -184,6 +185,14 @@ void PipelineFragmentContext::cancel(const PPlanFragmentCancelReason& reason, | |||
// make result receiver on fe be stocked on rpc forever until timeout... | |||
// We need a more detail discussion. | |||
_query_ctx->cancel(msg, Status::Cancelled(msg)); | |||
|
|||
if (reason == PPlanFragmentCancelReason::INTERNAL_ERROR && !msg.empty()) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这里单纯是为了输出一条log吗?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
是的,不然事后无法定位问题,也不知道pipeline到底卡在哪里了。
pick #39223 with some modifications. Optimization will only be applied to pipeline x.