This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 0711423ee3a [Chore](pipeline) set PipelineFragmentContext::_timeout
(#38890)
0711423ee3a is described below
commit 0711423ee3a7c1b6f663e50af485cd573487bdd0
Author: Gabriel <[email protected]>
AuthorDate: Mon Aug 5 21:47:08 2024 +0800
[Chore](pipeline) set PipelineFragmentContext::_timeout (#38890)
## Proposed changes
Now we use `query_timeout` to set a timeout value for queries. But for
pipelineX engine, Doris do not use it so each query will not end before
EOS. This PR fix it.
pick #35328
<!--Describe your changes.-->
---
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 3 +++
1 file changed, 3 insertions(+)
diff --git a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
index 90c5394debd..55a25718e00 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
@@ -178,6 +178,9 @@ Status PipelineXFragmentContext::prepare(const
doris::TPipelineFragmentParams& r
if (_prepared) {
return Status::InternalError("Already prepared");
}
+ if (request.__isset.query_options &&
request.query_options.__isset.execution_timeout) {
+ _timeout = request.query_options.execution_timeout;
+ }
_num_instances = request.local_params.size();
_total_instances = request.__isset.total_instances ?
request.total_instances : _num_instances;
_runtime_profile = std::make_unique<RuntimeProfile>("PipelineContext");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
