impala-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sailesh Mukil (Code Review)" <>
Subject [Impala-ASF-CR] IMPALA-3977: TransmitData() should not block
Date Thu, 15 Dec 2016 21:35:00 GMT
Sailesh Mukil has uploaded a new patch set (#2).

Change subject: IMPALA-3977: TransmitData() should not block

IMPALA-3977: TransmitData() should not block

TransmitData() calls effectively block until an error occurs (e.g.
datastream_sender_timeout_ms expires) or the RPC is serviced by the
receiver. This is bad for a variety of reasons, not least that it
makes it impossible to cancel the sender without also cancelling the
recipient (who might not even be running!).

With our current RPC stack, this holds up the connection for as long
as the receiver takes to get ready (or until it times out), which
means that that connection is unusable by other threads.

When we move to KuduRPC, we will have a different problem if this RPC
remains blocking, in that it will hold up a service thread on the
receiver side potentially blocking progress for other tasks on that
host that require a service thread.

This patch introduces a EAGAIN like error code that the receiver sends
back to the sender if the DataStreamReceiver object is not yet ready
to receive data. The sender tries again up to 5 times with intervals
in between.

Change-Id: I47f9d6c1de95a72ab73471dcd2a3118ef13e7db0
M be/src/runtime/
M be/src/runtime/data-stream-mgr.h
M be/src/runtime/
M common/thrift/
4 files changed, 85 insertions(+), 139 deletions(-)

  git pull ssh:// refs/changes/91/5491/2
To view, visit
To unsubscribe, visit

Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I47f9d6c1de95a72ab73471dcd2a3118ef13e7db0
Gerrit-PatchSet: 2
Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-Owner: Sailesh Mukil <>
Gerrit-Reviewer: Henry Robinson <>
Gerrit-Reviewer: Lars Volker <>
Gerrit-Reviewer: Sailesh Mukil <>

View raw message