[fix](memtracker) Remove useless memory exceed check #11939

2022-08-22 08:40:19 +08:00
parent 19496ef9a0
commit 5eb5444476
5 changed files with 6 additions and 23 deletions
--- a/be/src/vec/exec/file_scan_node.cpp
+++ b/be/src/vec/exec/file_scan_node.cpp
@ -403,11 +403,7 @@ Status FileScanNode::scanner_scan(const TFileScanRange& scan_range, ScannerCount
               // stop pushing more batch if
               // 1. too many batches in queue, or
               // 2. at least one batch in queue and memory exceed limit.
-               (_block_queue.size() >= _max_buffered_batches ||
-                (thread_context()
-                         ->_thread_mem_tracker_mgr->limiter_mem_tracker()
-                         ->any_limit_exceeded() &&
-                 !_block_queue.empty()))) {
+               (_block_queue.size() >= _max_buffered_batches || !_block_queue.empty())) {
            _queue_writer_cond.wait_for(l, std::chrono::seconds(1));
        }
        // Process already set failed, so we just return OK