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

[Refactor] remove some useless code (#8976)

Browse Source
This commit is contained in:
dataroaring
2022-04-18 09:55:54 +08:00
committed by GitHub
parent 04287cabb2
commit de7dce4df8
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
be/src/exec/tablet_sink.cpp
View File

@ -65,7 +65,6 @@ NodeChannel::~NodeChannel() noexcept {
delete _add_batch_closure;
_add_batch_closure = nullptr;
}
_cur_add_batch_request.release_id();
}
// if "_cancelled" is set to true,
@ -144,8 +143,6 @@ void NodeChannel::open() {
}
_stub->tablet_writer_open(&_open_closure->cntl, &request, &_open_closure->result,
_open_closure);
request.release_id();
request.release_schema();
}
void NodeChannel::_cancel_with_msg(const std::string& msg) {
@ -446,16 +443,13 @@ void NodeChannel::cancel(const std::string& cancel_msg) {
auto closure = new RefCountClosure<PTabletWriterCancelResult>();
closure->ref();
int remain_ms = _rpc_timeout_ms - _timeout_watch.elapsed_time() / NANOS_PER_MILLIS;
if (UNLIKELY(remain_ms < config::min_load_rpc_timeout_ms)) {
remain_ms = config::min_load_rpc_timeout_ms;
}
int remain_ms = std::max(_rpc_timeout_ms - _timeout_watch.elapsed_time() / NANOS_PER_MILLIS,
(unsigned long long)config::min_load_rpc_timeout_ms);
closure->cntl.set_timeout_ms(remain_ms);
if (config::tablet_writer_ignore_eovercrowded) {
closure->cntl.ignore_eovercrowded();
}
_stub->tablet_writer_cancel(&closure->cntl, &request, &closure->result, closure);
request.release_id();
}
int NodeChannel::try_send_and_fetch_status(RuntimeState* state,