diff --git a/be/src/pipeline/exec/set_probe_sink_operator.h b/be/src/pipeline/exec/set_probe_sink_operator.h
index 2fbed5e990..66db842fdd 100644
--- a/be/src/pipeline/exec/set_probe_sink_operator.h
+++ b/be/src/pipeline/exec/set_probe_sink_operator.h
@@ -55,7 +55,6 @@ public:
     Status sink(RuntimeState* state, vectorized::Block* block, SourceState source_state) override;
     Status finalize(RuntimeState* state) override;
     Status open(RuntimeState* /*state*/) override { return Status::OK(); }
-    Status close(RuntimeState* /*state*/) override { return Status::OK(); }
 
 private:
     int _child_id;
diff --git a/be/src/pipeline/exec/set_sink_operator.h b/be/src/pipeline/exec/set_sink_operator.h
index d729666ee9..2b8d17a137 100644
--- a/be/src/pipeline/exec/set_sink_operator.h
+++ b/be/src/pipeline/exec/set_sink_operator.h
@@ -50,8 +50,6 @@ public:
 
     bool can_write() override { return true; }
 
-    Status close(RuntimeState* /*state*/) override { return Status::OK(); };
-
 private:
     vectorized::VSetOperationNode<is_intersect>* _set_node;
 };