impala-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Michael Ho (Code Review)" <>
Subject [Impala-ASF-CR] IMPALA-4670: Introduces RpcMgr class
Date Thu, 05 Oct 2017 17:43:25 GMT
Michael Ho has posted comments on this change. ( )

Change subject: IMPALA-4670: Introduces RpcMgr class

Patch Set 6:

File be/src/rpc/rpc-mgr.h:
PS8, Line 90: t th
> this is kind of a detail but "some" implies that requests can bypass the qu
changed to "new requests"
PS8, Line 90: l fail
> threads
File be/src/rpc/rpc-mgr.h:
PS6, Line 76: ///
> Okay. The case I'm worried about with Shutdown() is if this happens while R
The shutdown of the ServicePool will wait for the exit of all service threads so all incoming
RPCs being processed would have been replied to before shutdown. All pending incoming RPCs
in the service queue will also be replied to too.

When shutting down the messenger, all thread pools (acceptor threads, negotiation threads
and reactor threads) encapsulated by it will be shut down too.
File be/src/scheduling/
PS8, Line 72: r_.
> delete
File be/src/service/
PS8, Line 1662:   item.key = local_backend_id;
> okay. or maybe the exec env should just have the resolved IP in it from Exe
I was wondering if the old code intentionally did an IP address resolution above to capture
any change from hostname to IP address ? I suppose it's a fair assumption that any IP address
change will involve restarting the cluster so it should be fine to cache the IP.

To view, visit
To unsubscribe, visit

Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: comment
Gerrit-Change-Id: I8adb10ae375d7bf945394c38a520f12d29cf7b46
Gerrit-Change-Number: 7901
Gerrit-PatchSet: 6
Gerrit-Owner: Michael Ho <>
Gerrit-Reviewer: Dan Hecht <>
Gerrit-Reviewer: Michael Ho <>
Gerrit-Reviewer: Sailesh Mukil <>
Gerrit-Comment-Date: Thu, 05 Oct 2017 17:43:25 +0000
Gerrit-HasComments: Yes

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