Hello Impala Public Jenkins,
I'd like you to reexamine a change. Please visit
http://gerrit.cloudera.org:8080/22506
to look at the new patch set (#2).
Change subject: Stop the fragment if all exchange receivers are closed
......................................................................
Stop the fragment if all exchange receivers are closed
If every receiver for an exchange is closed, there is no need
to keep running the fragment producing the row batches. This
can happen if all the receiving fragments have a tuple cache
hit and don't need the rows.
This keeps an atomic counter on the krpc data stream sender
and returns eos from Send() if the counter reaches the total
number of channels.
Change-Id: I02a3c507755d0c15994dc0fbfdb4f6540ddf16ba
(cherry picked from commit 71a128f5c05da13579699f0a0c7a316af919bc62)
---
M be/src/runtime/krpc-data-stream-sender.cc
M be/src/runtime/krpc-data-stream-sender.h
2 files changed, 21 insertions(+), 1 deletion(-)
git pull ssh://gerrit.cloudera.org:29418/Impala-ASF refs/changes/06/22506/2
--
To view, visit http://gerrit.cloudera.org:8080/22506
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings
Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I02a3c507755d0c15994dc0fbfdb4f6540ddf16ba
Gerrit-Change-Number: 22506
Gerrit-PatchSet: 2
Gerrit-Owner: Joe McDonnell <[email protected]>
Gerrit-Reviewer: Impala Public Jenkins <[email protected]>
