This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch scanner_refactor in repository https://gitbox.apache.org/repos/asf/doris.git
commit 7929c6b3d9a7419a792aa4c6ce1ea5d21f52ac9e Author: yiguolei <[email protected]> AuthorDate: Thu Aug 20 14:57:13 2026 +0800 f --- be/test/exec/scan/scanner_context_test.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/be/test/exec/scan/scanner_context_test.cpp b/be/test/exec/scan/scanner_context_test.cpp index 1928062abbd..920f98296f5 100644 --- a/be/test/exec/scan/scanner_context_test.cpp +++ b/be/test/exec/scan/scanner_context_test.cpp @@ -677,17 +677,17 @@ TEST_F(ScannerContextTest, pull_next_scan_task) { scanner_context->_pending_tasks = std::stack<std::shared_ptr<ScanTask>>(); scanner_context->_completed_tasks.clear(); scanner_context->_in_flight_tasks_num = 0; - // Even if the effective limit is temporarily zero, one pending task must run so it can publish - // a block or EOS and prevent the Context from stalling. - scanner_context->_max_scan_concurrency = 0; + // Even if the effective limit is temporarily zero, one pending task must run so it can publish + // a block or EOS and prevent the Context from stalling. + scanner_context->_max_scan_concurrency = 0; auto completed_task = std::make_shared<ScanTask>(std::make_shared<ScannerDelegate>(scanner)); completed_task->set_state(ScanTask::State::IN_FLIGHT); completed_task->cached_block = Block::create_unique(); completed_task->set_state(ScanTask::State::COMPLETED); completed_task->cached_block.reset(); - // A consumed non-EOS result must be eligible for another Context admission. This also covers - // the COMPLETED -> PENDING transition used by ThreadPool scheduling. + // A consumed non-EOS result must be eligible for another Context admission. This also covers + // the COMPLETED -> PENDING transition used by ThreadPool scheduling. scanner_context->push_pending_scan_task(completed_task, context_transfer_lock); EXPECT_FALSE(scanner_context->is_context_queued(context_transfer_lock)); @@ -695,7 +695,7 @@ TEST_F(ScannerContextTest, pull_next_scan_task) { EXPECT_TRUE(scanner_context->is_context_queued(context_transfer_lock)); scanner_context->set_context_queued(false, context_transfer_lock); - // The Context can admit exactly one scanner at its configured concurrency limit. + // The Context can admit exactly one scanner at its configured concurrency limit. auto admitted_task = scanner_context->try_get_next_scan_task(context_transfer_lock); EXPECT_EQ(admitted_task, completed_task); EXPECT_EQ(admitted_task->_state, ScanTask::State::IN_FLIGHT); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
