Aleksandr Efimov has uploaded this change for review. ( http://gerrit.cloudera.org:8080/24375
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: - ./buildall.sh -skiptests -noclean -ninja - 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, 127 insertions(+), 19 deletions(-) git pull ssh://gerrit.cloudera.org:29418/Impala-ASF refs/changes/75/24375/1 -- 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: newchange Gerrit-Change-Id: I5efe8016b268e3707a2b7b99c488de69ccdad8e6 Gerrit-Change-Number: 24375 Gerrit-PatchSet: 1 Gerrit-Owner: Aleksandr Efimov <[email protected]>
