yiguolei commented on code in PR #39927: URL: https://github.com/apache/doris/pull/39927#discussion_r1731238629
########## be/src/pipeline/exec/scan_operator.cpp: ########## @@ -1423,6 +1417,31 @@ Status ScanOperatorX<LocalStateType>::init(const TPlanNode& tnode, RuntimeState* if (tnode.__isset.topn_filter_source_node_ids) { topn_filter_source_node_ids = tnode.topn_filter_source_node_ids; } + + // The first branch is kept for compatibility with the old version of the FE + if (!state->query_options().__isset.enable_adaptive_pipeline_task_serial_read_on_limit) { + if (!tnode.__isset.conjuncts || tnode.conjuncts.empty()) { + // Which means the request could be fullfilled in a single segment iterator request. + if (tnode.limit > 0 && tnode.limit <= 8192) { + _should_run_serial = true; + } + } + } else { + if (state->query_options().enable_adaptive_pipeline_task_serial_read_on_limit) { + int32_t adaptive_pipeline_task_serial_read_on_limit = 8192; Review Comment: 所有访问thrift 里的字段,都要先判断isset,然后再get 里面的值 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org