diff --git a/be/src/pipeline/pipeline_task.h b/be/src/pipeline/pipeline_task.h index 1cd150d319357f..f54948d6df52b0 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 @@ class PipelineTask { RuntimeProfile::Counter* _pip_task_total_timer; }; -} // namespace doris::pipeline \ No newline at end of file +} // namespace doris::pipeline