Hello Csaba Ringhofer, Impala Public Jenkins,
I'd like you to reexamine a change. Please visit
http://gerrit.cloudera.org:8080/24375
to look at the new patch set (#2).
Change subject: IMPALA-14838: Count open deferred RPC intervals
......................................................................
IMPALA-14838: Count open deferred RPC intervals
TotalHasDeferredRPCsTime was only updated when a sender queue drained
its deferred RPC queue. If the queue was still non-empty when the
profile was sampled, the counter stayed at zero even though RPCs had
been deferred.
Track each sender queue deferred-RPC interval separately and expose
TotalHasDeferredRPCsTime as a derived counter. The derived counter
includes both completed intervals and any interval that is currently
open.
Add a data-stream regression test that keeps the receiver reader
stopped, waits until an RPC is deferred, and verifies that the live
profile reports deferred RPC time before cancellation drains the queue.
Testing:
- be/build/latest/runtime/data-stream-test with filter:
DataStreamTest.TotalHasDeferredRpcsTimeIncludesOpenInterval
- be/build/latest/runtime/data-stream-test
Generated-by: OpenAI Codex
Change-Id: I5efe8016b268e3707a2b7b99c488de69ccdad8e6
---
M be/src/runtime/data-stream-test.cc
M be/src/runtime/krpc-data-stream-recvr.cc
2 files changed, 129 insertions(+), 20 deletions(-)
git pull ssh://gerrit.cloudera.org:29418/Impala-ASF refs/changes/75/24375/2
--
To view, visit http://gerrit.cloudera.org:8080/24375
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings
Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I5efe8016b268e3707a2b7b99c488de69ccdad8e6
Gerrit-Change-Number: 24375
Gerrit-PatchSet: 2
Gerrit-Owner: Aleksandr Efimov <[email protected]>
Gerrit-Reviewer: Csaba Ringhofer <[email protected]>
Gerrit-Reviewer: Impala Public Jenkins <[email protected]>
