Skip to content

Commit

Permalink
pass code static check
Browse files Browse the repository at this point in the history
  • Loading branch information
bestwoody committed Apr 14, 2022
1 parent df7fd41 commit d4da69a
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions dbms/src/Flash/Mpp/MPPTunnel.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ MPPTunnelBase<Writer>::MPPTunnelBase(
, timeout(timeout_)
, task_cancelled_callback(std::move(callback))
, tunnel_id(fmt::format("tunnel{}+{}", sender_meta_.task_id(), receiver_meta_.task_id()))
, send_loop_msg("")
, input_streams_num(input_steams_num_)
, send_thread(nullptr)
, send_queue(std::max(5, input_steams_num_ * 5)) /// the queue should not be too small to push the last nullptr or error msg. TODO(fzh) set a reasonable parameter
Expand Down Expand Up @@ -149,7 +148,7 @@ void MPPTunnelBase<Writer>::sendLoop()
if (!writer->Write(*res))
{
finishWithLock();
auto msg = " grpc writes failed.";
const char * msg = " grpc writes failed.";
LOG_ERROR(log, msg);
throw Exception(tunnel_id + msg);
}
Expand Down

0 comments on commit d4da69a

Please sign in to comment.