This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new d59503a0ff fix for pick commit
54795289dcd88e7cf08a86dc344ba4c4e94bf0f1 [Bug](pipeline) adjust scanner
scheduler.submit and _num_scheduling_ctx maintain adjust scanner
scheduler.submit and _num_scheduling_ctx maintain
d59503a0ff is described below
commit d59503a0ff112bb89d40d2f2a348e982516bb2ef
Author: Kang <[email protected]>
AuthorDate: Wed Jul 19 00:59:53 2023 +0800
fix for pick commit 54795289dcd88e7cf08a86dc344ba4c4e94bf0f1
[Bug](pipeline) adjust scanner scheduler.submit and _num_scheduling_ctx
maintain
adjust scanner scheduler.submit and _num_scheduling_ctx maintain
---
be/src/pipeline/pipeline_task.h | 17 ++---------------
1 file changed, 2 insertions(+), 15 deletions(-)
diff --git a/be/src/pipeline/pipeline_task.h b/be/src/pipeline/pipeline_task.h
index 1cd150d319..f54948d6df 100644
--- a/be/src/pipeline/pipeline_task.h
+++ b/be/src/pipeline/pipeline_task.h
@@ -112,20 +112,7 @@ class PipelineTask {
public:
PipelineTask(PipelinePtr& pipeline, uint32_t index, RuntimeState* state,
Operators& operators,
OperatorPtr& sink, PipelineFragmentContext* fragment_context,
- RuntimeProfile* parent_profile)
- : _index(index),
- _pipeline(pipeline),
- _operators(operators),
- _source(_operators.front()),
- _root(_operators.back()),
- _sink(sink),
- _prepared(false),
- _opened(false),
- _state(state),
- _cur_state(PipelineTaskState::NOT_READY),
- _data_state(SourceState::DEPEND_ON_SOURCE),
- _fragment_context(fragment_context),
- _parent_profile(parent_profile) {}
+ RuntimeProfile* parent_profile);
Status prepare(RuntimeState* state);
@@ -357,4 +344,4 @@ private:
RuntimeProfile::Counter* _pip_task_total_timer;
};
-} // namespace doris::pipeline
\ No newline at end of file
+} // namespace doris::pipeline
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
