[only test] #44427
[only test] #44427
Conversation
|
Thank you for your contribution to Apache Doris. Please clearly describe your PR:
|
![github-actions[bot]](https://avatars.githubusercontent.com/in/15368?s=60&v=4){kind=small}
| @@ -211,8 +208,6 @@ Status ExchangeSinkBuffer::add_block(BroadcastTransmitInfo&& request) { | |||
| Status ExchangeSinkBuffer::_send_rpc(InstanceLoId id) { | |||
There was a problem hiding this comment.
warning: function '_send_rpc' has cognitive complexity of 71 (threshold 50) [readability-function-cognitive-complexity]
Status ExchangeSinkBuffer::_send_rpc(InstanceLoId id) {
^Additional context
be/src/pipeline/exec/exchange_sink_buffer.cpp:214: +1, including nesting penalty of 0, nesting level increased to 1
if (_is_finishing) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:218: +1, including nesting penalty of 0, nesting level increased to 1
if (_instance_to_receiver_eof[id]) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:222: +1, including nesting penalty of 0, nesting level increased to 1
if (!q.empty()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:230: +2, including nesting penalty of 1, nesting level increased to 2
if (request.block && !request.block->column_metas().empty()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:230: +1
if (request.block && !request.block->column_metas().empty()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:233: +2, including nesting penalty of 1, nesting level increased to 2
if (!request.exec_status.ok()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:239: +2, including nesting penalty of 1, nesting level increased to 2
if (config::execution_ignore_eovercrowded) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:242: nesting level increased to 2
send_callback->addFailedHandler([&, weak_task_ctx = weak_task_exec_ctx()](
^be/src/pipeline/exec/exchange_sink_buffer.cpp:245: +3, including nesting penalty of 2, nesting level increased to 3
if (task_lock == nullptr) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:254: nesting level increased to 2
send_callback->addSuccessHandler([&, weak_task_ctx = weak_task_exec_ctx()](
^be/src/pipeline/exec/exchange_sink_buffer.cpp:259: +3, including nesting penalty of 2, nesting level increased to 3
if (task_lock == nullptr) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:270: +3, including nesting penalty of 2, nesting level increased to 3
if (s.is<ErrorCode::END_OF_FILE>()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:272: +1, nesting level increased to 3
} else if (!s.ok()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:276: +1, nesting level increased to 3
} else if (eos) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:281: +3, including nesting penalty of 2, nesting level increased to 3
if (!s) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:292: +2, including nesting penalty of 1, nesting level increased to 2
if (enable_http_send_block(*brpc_request)) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:293: +3, including nesting penalty of 2, nesting level increased to 3
RETURN_IF_ERROR(transmit_block_httpv2(_context->exec_env(),
^be/src/common/status.h:632: expanded from macro 'RETURN_IF_ERROR'
do { \
^be/src/pipeline/exec/exchange_sink_buffer.cpp:293: +4, including nesting penalty of 3, nesting level increased to 4
RETURN_IF_ERROR(transmit_block_httpv2(_context->exec_env(),
^be/src/common/status.h:634: expanded from macro 'RETURN_IF_ERROR'
if (UNLIKELY(!_status_.ok())) { \
^be/src/pipeline/exec/exchange_sink_buffer.cpp:296: +1, nesting level increased to 2
} else {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:301: +2, including nesting penalty of 1, nesting level increased to 2
if (request.block) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:308: +2, including nesting penalty of 1, nesting level increased to 2
if (_total_queue_size <= _queue_capacity) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:313: +1, nesting level increased to 1
} else if (!broadcast_q.empty()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:321: +2, including nesting penalty of 1, nesting level increased to 2
if (request.block_holder->get_block() &&
^be/src/pipeline/exec/exchange_sink_buffer.cpp:321: +1
if (request.block_holder->get_block() &&
^be/src/pipeline/exec/exchange_sink_buffer.cpp:327: +2, including nesting penalty of 1, nesting level increased to 2
if (config::execution_ignore_eovercrowded) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:330: nesting level increased to 2
send_callback->addFailedHandler([&, weak_task_ctx = weak_task_exec_ctx()](
^be/src/pipeline/exec/exchange_sink_buffer.cpp:333: +3, including nesting penalty of 2, nesting level increased to 3
if (task_lock == nullptr) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:342: nesting level increased to 2
send_callback->addSuccessHandler([&, weak_task_ctx = weak_task_exec_ctx()](
^be/src/pipeline/exec/exchange_sink_buffer.cpp:347: +3, including nesting penalty of 2, nesting level increased to 3
if (task_lock == nullptr) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:358: +3, including nesting penalty of 2, nesting level increased to 3
if (s.is<ErrorCode::END_OF_FILE>()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:360: +1, nesting level increased to 3
} else if (!s.ok()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:364: +1, nesting level increased to 3
} else if (eos) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:369: +3, including nesting penalty of 2, nesting level increased to 3
if (!s) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:380: +2, including nesting penalty of 1, nesting level increased to 2
if (enable_http_send_block(*brpc_request)) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:381: +3, including nesting penalty of 2, nesting level increased to 3
RETURN_IF_ERROR(transmit_block_httpv2(_context->exec_env(),
^be/src/common/status.h:632: expanded from macro 'RETURN_IF_ERROR'
do { \
^be/src/pipeline/exec/exchange_sink_buffer.cpp:381: +4, including nesting penalty of 3, nesting level increased to 4
RETURN_IF_ERROR(transmit_block_httpv2(_context->exec_env(),
^be/src/common/status.h:634: expanded from macro 'RETURN_IF_ERROR'
if (UNLIKELY(!_status_.ok())) { \
^be/src/pipeline/exec/exchange_sink_buffer.cpp:384: +1, nesting level increased to 2
} else {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:389: +2, including nesting penalty of 1, nesting level increased to 2
if (request.block_holder->get_block()) {
^be/src/pipeline/exec/exchange_sink_buffer.cpp:393: +1, nesting level increased to 1
} else {
^| @@ -18,6 +18,7 @@ | |||
| #pragma once | |||
|
|
|||
| #include <gen_cpp/Types_types.h> | |||
There was a problem hiding this comment.
warning: 'gen_cpp/Types_types.h' file not found [clang-diagnostic-error]
#include <gen_cpp/Types_types.h>
^
|
run buildall |
TPC-H: Total hot run time: 41714 ms |
|
TeamCity be ut coverage result: |
Mryange
force-pushed
the
poc-rpc-single-eof-dev-11-21-22-22
branch
from
239bebb to
5cda382
Compare
|
run buildall |
Mryange
force-pushed
the
poc-rpc-single-eof-dev-11-21-22-22
branch
from
5cda382 to
e9c0636
Compare
|
run buildall |
1 similar comment
|
run buildall |
|
TeamCity be ut coverage result: |
TPC-H: Total hot run time: 39565 ms |
TPC-DS: Total hot run time: 197988 ms |
ClickBench: Total hot run time: 32.38 s |
What problem does this PR solve?
Issue Number: close #xxx
Related PR: #xxx
Problem Summary:
Release note
None
Check List (For Author)
Test
Behavior changed:
Does this need documentation?
Check List (For Reviewer who merge this PR)