fix for pick commit 5479528

[Bug](pipeline) adjust scanner scheduler.submit and _num_scheduling_ctx maintain adjust scanner scheduler.submit and _num_scheduling_ctx maintain
LHG41278 · Jul 18, 2023 · d59503a · d59503a
1 parent 90d16e4
commit d59503a
Showing 1 changed file with 2 additions and 15 deletions.
diff --git 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 @@ class PipelineTask {
 
     RuntimeProfile::Counter* _pip_task_total_timer;
 };
-} // namespace doris::pipeline
+} // namespace doris::pipeline