diff --git a/be/src/pipeline/pipeline_task.h b/be/src/pipeline/pipeline_task.h
index f8027626019db4..dd2ead4b5dcc91 100644
--- a/be/src/pipeline/pipeline_task.h
+++ b/be/src/pipeline/pipeline_task.h
@@ -283,8 +283,8 @@ class PipelineTask {
     MonotonicStopWatch _pipeline_task_watcher;
 
     Operators _operators; // left is _source, right is _root
-    OperatorBase* _source;
-    OperatorBase* _root;
+    OperatorXBase* _source;
+    OperatorXBase* _root;
     DataSinkOperatorPtr _sink;
 
     // `_read_dependencies` is stored as same order as `_operators`