From f1321c2fed358fa19168eb1776bc2b6dd277cfc7 Mon Sep 17 00:00:00 2001 From: Jerry Hu Date: Mon, 19 Dec 2022 14:09:36 +0800 Subject: [PATCH] [fix](pipeline) remove the redundant override of the close function in set operators (#15161) --- be/src/pipeline/exec/set_probe_sink_operator.h | 1 - be/src/pipeline/exec/set_sink_operator.h | 2 -- 2 files changed, 3 deletions(-) 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* _set_node; };