update

apache · Aug 24, 2023 · ef92e6a · ef92e6a
1 parent b918840
commit ef92e6a
Showing 1 changed file with 6 additions and 3 deletions.
diff --git 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;