database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[coverage](pipeline) Remove unless code and add call method for coverage (#25552)

Browse Source 
Remove unless code and add call method for coverage
This commit is contained in:
HappenLee
2023-10-23 15:52:43 +08:00
committed by GitHub
parent b8452812df
commit 5cb5121cf6
4 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/pipeline/exec/exchange_sink_operator.h
View File

@ -57,8 +57,6 @@ public:
Status close(RuntimeState* state) override;
RuntimeState* state() { return _state; }
private:
std::unique_ptr<ExchangeSinkBuffer<vectorized::VDataStreamSender>> _sink_buffer;
int _dest_node_id = -1;

2
be/src/pipeline/exec/multi_cast_data_stream_sink.h
View File

@ -38,7 +38,7 @@ public:
MultiCastDataStreamSinkOperator(OperatorBuilderBase* operator_builder, DataSink* sink)
: DataSinkOperator(operator_builder, sink) {}
bool can_write() override { return true; }
bool can_write() override { return _sink->can_write(); }
};
class MultiCastDataStreamSinkOperatorX;

4
be/src/util/proto_util.h
View File

@ -45,9 +45,7 @@ Status request_embed_attachment_contain_block(Params* brpc_request, Closure* clo
return st;
}
inline bool enable_http_send_block(
const PTransmitDataParams& request,
bool transfer_large_data_by_brpc = config::transfer_large_data_by_brpc) {
inline bool enable_http_send_block(const PTransmitDataParams& request) {
if (!config::transfer_large_data_by_brpc) {
return false;
}

2
be/src/vec/sink/vdata_stream_sender.cpp
View File

@ -207,7 +207,7 @@ Status Channel<Parent>::send_remote_block(PBlock* block, bool eos, Status exec_s
{
SCOPED_SWITCH_THREAD_MEM_TRACKER_LIMITER(ExecEnv::GetInstance()->orphan_mem_tracker());
if (enable_http_send_block(_brpc_request, config::transfer_large_data_by_brpc)) {
if (enable_http_send_block(_brpc_request)) {
RETURN_IF_ERROR(transmit_block_http(_state->exec_env(), _closure, _brpc_request,
_brpc_dest_addr));
} else {