diff --git a/be/src/pipeline/exec/union_source_operator.cpp b/be/src/pipeline/exec/union_source_operator.cpp
index cac6ee7a73397f..f2f4ca82e4c393 100644
--- a/be/src/pipeline/exec/union_source_operator.cpp
+++ b/be/src/pipeline/exec/union_source_operator.cpp
@@ -181,10 +181,6 @@ Status UnionSourceOperatorX::get_block(RuntimeState* state, vectorized::Block* b
     return Status::OK();
 }
 
-bool UnionSourceOperatorX::need_data_from_children(RuntimeState* state) const {
-    return !_has_data(state);
-}
-
 Status UnionSourceOperatorX::get_next_const(RuntimeState* state, vectorized::Block* block) {
     DCHECK_EQ(state->per_fragment_instance_idx(), 0);
     auto& local_state = state->get_local_state(operator_id())->cast<UnionSourceLocalState>();
diff --git a/be/src/pipeline/exec/union_source_operator.h b/be/src/pipeline/exec/union_source_operator.h
index 89969f90d49c29..69e81bcd4fcf70 100644
--- a/be/src/pipeline/exec/union_source_operator.h
+++ b/be/src/pipeline/exec/union_source_operator.h
@@ -131,8 +131,6 @@ class UnionSourceOperatorX final : public OperatorX<UnionSourceLocalState> {
     }
     [[nodiscard]] int get_child_count() const { return _child_size; }
 
-    bool need_data_from_children(RuntimeState* state) const override;
-
 private:
     bool _has_data(RuntimeState* state) const {
         auto& local_state = state->get_local_state(operator_id())->cast<UnionSourceLocalState>();