Impala Public Jenkins has posted comments on this change. ( http://gerrit.cloudera.org:8080/20810 )
Change subject: WIP: Skip KRPC in local exchanges ...................................................................... Patch Set 1: (12 comments) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-recvr.cc File be/src/runtime/krpc-data-stream-recvr.cc: http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-recvr.cc@338 PS1, Line 338: if (payload->rpc_context != nullptr) TRACE_TO(payload->rpc_context->trace(), "Enqueuing deferred RPC"); line too long (105 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-recvr.cc@487 PS1, Line 487: //TRACE_TO(rpc_context->trace(), "Failed to deserialize batch: $0", status.GetDetail()); line too long (92 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-recvr.cc@637 PS1, Line 637: if (ctx->rpc_context != nullptr) TRACE_TO(ctx->rpc_context->trace(), "Batch queue is full"); line too long (99 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-recvr.cc@660 PS1, Line 660: if (ctx->rpc_context != nullptr) recvr_->deferred_rpc_tracker()->Release(ctx->rpc_context->GetTransferSize()); line too long (114 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-recvr.cc@665 PS1, Line 665: if (ctx->rpc_context != nullptr) DataStreamService::RespondRpc(status, ctx->response, ctx->rpc_context); line too long (106 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-recvr.cc@772 PS1, Line 772: //LOG(INFO) << "KrpcDataStreamRecvr::SenderQueue::Close() data_arrival_cv_.wait(l) finished"; line too long (95 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-sender.cc File be/src/runtime/krpc-data-stream-sender.cc: http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-sender.cc@174 PS1, Line 174: Status Init(RuntimeState* state, std::shared_ptr<CharMemTrackerAllocator> allocator, bool partitioned); line too long (105 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-sender.cc@388 PS1, Line 388: RuntimeState* state, std::shared_ptr<CharMemTrackerAllocator> allocator, bool partitioned) { line too long (96 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/krpc-data-stream-sender.cc@876 PS1, Line 876: RETURN_IF_ERROR(channels_[i]->Init(state, char_mem_tracker_allocator_, partition_type_ != TPartitionType::UNPARTITIONED)); line too long (126 > 90) http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/local-row-batch-channel.h File be/src/runtime/local-row-batch-channel.h: http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/local-row-batch-channel.h@38 PS1, Line 38: line has trailing whitespace http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/local-row-batch-channel.cc File be/src/runtime/local-row-batch-channel.cc: http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/local-row-batch-channel.cc@43 PS1, Line 43: line has trailing whitespace http://gerrit.cloudera.org:8080/#/c/20810/1/be/src/runtime/local-row-batch-channel.cc@123 PS1, Line 123: line has trailing whitespace -- To view, visit http://gerrit.cloudera.org:8080/20810 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: Impala-ASF Gerrit-Branch: master Gerrit-MessageType: comment Gerrit-Change-Id: Iee16cd943d76d04874bce7f3959e74b4685adb6e Gerrit-Change-Number: 20810 Gerrit-PatchSet: 1 Gerrit-Owner: Csaba Ringhofer <[email protected]> Gerrit-Reviewer: Impala Public Jenkins <[email protected]> Gerrit-Comment-Date: Sun, 17 Dec 2023 09:48:50 +0000 Gerrit-HasComments: Yes
