Riza Suminto has uploaded this change for review. ( 
http://gerrit.cloudera.org:8080/18243


Change subject: IMPALA-10049: Include RPC call_id in slow RPC logs
......................................................................

IMPALA-10049: Include RPC call_id in slow RPC logs

KRPC log slow RPC trace in the receiver side. The trace log has the
call_id info that matches with the sender. However, our slow RPC logging
in the sender side does not log this call_id. It is hard to associate
the slow RPC logs between sender and receiver.

With the recent KRPC rebase in IMPALA-10931, we can now log the call_id
on the sender side.

Testing:
I tested this with a low threshold and delays added (the same as we did
in IMPALA-9128):

  start-impala-cluster.py \
      --impalad_args=--impala_slow_rpc_threshold_ms=1 \
      --impalad_args=--debug_actions=END_DATA_STREAM_DELAY:JITTER@3000@1.0

The following is how the logs look like on the sender and receiver sides:

impalad_node1.INFO (sender):
I0217 10:29:36.278754  6606 krpc-data-stream-sender.cc:394] Slow TransmitData 
RPC (request call id 414) to 127.0.0.1:27002 
(fragment_instance_id=d8453c2785c38df4:3473e28b00000041): took 343.279ms. 
Receiver time: 342.780ms Network time: 498.405us

impalad_node2.INFO (receiver):
I0217 10:29:36.278379  6775 rpcz_store.cc:269] Call 
impala.DataStreamService.TransmitData from 127.0.0.1:39702 (request call id 
414) took 342ms. Trace:
I0217 10:29:36.278479  6775 rpcz_store.cc:270] 0217 10:29:35.935586 (+     0us) 
impala-service-pool.cc:179] Inserting onto call queue
0217 10:29:36.277730 (+342144us) impala-service-pool.cc:278] Handling call
0217 10:29:36.277859 (+   129us) krpc-data-stream-recvr.cc:397] Deserializing 
batch
0217 10:29:36.278330 (+   471us) krpc-data-stream-recvr.cc:424] Enqueuing 
deserialized batch
0217 10:29:36.278369 (+    39us) inbound_call.cc:171] Queueing success response
Metrics: {}

Change-Id: I7fb5746fa0be575745a8e168405d43115c425389
---
M be/src/runtime/krpc-data-stream-sender.cc
1 file changed, 4 insertions(+), 2 deletions(-)



  git pull ssh://gerrit.cloudera.org:29418/Impala-ASF refs/changes/43/18243/1
--
To view, visit http://gerrit.cloudera.org:8080/18243
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings

Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: newchange
Gerrit-Change-Id: I7fb5746fa0be575745a8e168405d43115c425389
Gerrit-Change-Number: 18243
Gerrit-PatchSet: 1
Gerrit-Owner: Riza Suminto <riza.sumi...@cloudera.com>

Reply via email to