From ef92e6ab5f528712b222f789fb55697a7c8f6abe Mon Sep 17 00:00:00 2001 From: Gabriel Date: Thu, 24 Aug 2023 09:49:57 +0800 Subject: [PATCH] update --- be/src/pipeline/pipeline_task.h | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/be/src/pipeline/pipeline_task.h b/be/src/pipeline/pipeline_task.h index dcd65c469b738b..34382a3f7c5356 100644 --- a/be/src/pipeline/pipeline_task.h +++ b/be/src/pipeline/pipeline_task.h @@ -152,7 +152,10 @@ class PipelineTask { return false; } - bool source_can_read() { return _source->can_read() || ignore_blocking_source();; } + bool source_can_read() { + return _source->can_read() || ignore_blocking_source(); + ; + } bool runtime_filters_are_ready_or_timeout() { return _source->runtime_filters_are_ready_or_timeout(); @@ -183,9 +186,9 @@ class PipelineTask { * 1. if any operator in pipeline can terminate early, this task should never be blocked by source operator. * 2. if the last operator (except sink) can terminate early, this task should never be blocked by sink operator. */ - [[nodiscard]] virtual bool ignore_blocking_sink() { return _root->can_terminate_early(); } + [[nodiscard]] bool ignore_blocking_sink() { return _root->can_terminate_early(); } - [[nodiscard]] virtual bool ignore_blocking_source() { + [[nodiscard]] bool ignore_blocking_source() { for (size_t i = 1; i < _operators.size(); i++) { if (_operators[i]->can_terminate_early()) { return true;