This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch spill_repartition in repository https://gitbox.apache.org/repos/asf/doris.git
commit 36e30046fd4ada26db2bf5d13f81c41e1c0dca68 Author: yiguolei <[email protected]> AuthorDate: Tue Mar 3 21:49:06 2026 +0800 simplify code --- be/src/pipeline/exec/multi_cast_data_streamer.h | 2 +- be/src/vec/spill/spill_file.h | 2 -- be/src/vec/spill/spill_file_writer.h | 2 -- 3 files changed, 1 insertion(+), 5 deletions(-) diff --git a/be/src/pipeline/exec/multi_cast_data_streamer.h b/be/src/pipeline/exec/multi_cast_data_streamer.h index 5e8526c8dda..95e838be064 100644 --- a/be/src/pipeline/exec/multi_cast_data_streamer.h +++ b/be/src/pipeline/exec/multi_cast_data_streamer.h @@ -101,7 +101,7 @@ private: Status _start_spill_task(RuntimeState* state, vectorized::SpillFileSPtr spill_file); - Status _trigger_spill_if_need(RuntimeState* state, bool* triggered); + Status _trigger_spill_if_need(RuntimeState* state); RuntimeProfile* _profile = nullptr; std::list<MultiCastBlock> _multi_cast_blocks; diff --git a/be/src/vec/spill/spill_file.h b/be/src/vec/spill/spill_file.h index 82b253d8d07..2d938d98fdb 100644 --- a/be/src/vec/spill/spill_file.h +++ b/be/src/vec/spill/spill_file.h @@ -74,8 +74,6 @@ public: void gc(); - int64_t get_written_bytes() const { return _total_written_bytes; } - /// Returns true after the writer has been closed (all data flushed). bool ready_for_reading() const { return _ready_for_reading; } diff --git a/be/src/vec/spill/spill_file_writer.h b/be/src/vec/spill/spill_file_writer.h index 243ae3f5c61..2e45c8ae32c 100644 --- a/be/src/vec/spill/spill_file_writer.h +++ b/be/src/vec/spill/spill_file_writer.h @@ -61,8 +61,6 @@ public: /// After close(), no more writes are allowed. Status close(); - int64_t get_written_bytes() const { return _total_written_bytes; } - private: /// Open the next part file (spill_dir/{_current_part_index}). Status _open_next_part(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
