impala-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Lars Volker (Code Review)" <>
Subject [Impala-ASF-CR] IMPALA-6193: Track memory of incoming data streams
Date Thu, 04 Jan 2018 17:24:05 GMT
Hello Michael Ho, Bikramjeet Vig, 

I'd like you to reexamine a change. Please visit

to look at the new patch set (#3).

Change subject: IMPALA-6193: Track memory of incoming data streams

IMPALA-6193: Track memory of incoming data streams

This change adds memory tracking to incoming transmit data RPCs when
using KRPC. We track memory against a global tracker called "Data Stream
Service" until it is handed over to the stream manager. There we track
it in a global tracker called "Data Stream Manager" until a receiver
registers and takes over the early sender RPCs. Inside the receiver,
memory for deferred RPCs is tracked against the fragment instance's
memtracker until we unpack the batches and add them to the row batch

The DCHECK in MemTracker::Close() covers that all memory consumed by a
tracker gets release eventually. In addition to that, this change adds a
custom cluster test that makes sure that queued memory gets tracked by
inspecting the peak consumption of the new memtrackers.

Change-Id: I2df1204d2483313a8a18e5e3be6cec9e402614c4
M be/src/rpc/
M be/src/rpc/impala-service-pool.h
M be/src/rpc/
M be/src/rpc/rpc-mgr.h
M be/src/runtime/
M be/src/runtime/
M be/src/runtime/krpc-data-stream-mgr.h
A be/src/runtime/krpc-data-stream-mgr.inline.h
M be/src/runtime/
M be/src/runtime/krpc-data-stream-recvr.h
M be/src/runtime/mem-tracker.h
M be/src/util/memory-metrics.h
M common/protobuf/data_stream_service.proto
A tests/custom_cluster/
A tests/verifiers/
15 files changed, 432 insertions(+), 161 deletions(-)

  git pull ssh:// refs/changes/14/8914/3
To view, visit
To unsubscribe, visit

Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I2df1204d2483313a8a18e5e3be6cec9e402614c4
Gerrit-Change-Number: 8914
Gerrit-PatchSet: 3
Gerrit-Owner: Lars Volker <>
Gerrit-Reviewer: Bikramjeet Vig <>
Gerrit-Reviewer: Lars Volker <>
Gerrit-Reviewer: Michael Ho <>

  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message