Skip to content

Conversation

@rxin
Copy link
Contributor

@rxin rxin commented Oct 14, 2015

A few more changes:

  1. Renamed IDVerifier -> RpcEndpointVerifier
  2. Renamed NettyRpcAddress -> RpcEndpointAddress
  3. Simplified NettyRpcHandler a bit by removing the connection count tracking. This is OK because I now force spark.shuffle.io.numConnectionsPerPeer to 1
  4. Reduced spark.rpc.connect.threads to 64. It would be great to eventually remove this extra thread pool.
  5. Minor cleanup & documentation.

@rxin
Copy link
Contributor Author

rxin commented Oct 14, 2015

cc @zsxwing

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this is not used anywhere

@zsxwing
Copy link
Member

zsxwing commented Oct 14, 2015

LGTM

@SparkQA
Copy link

SparkQA commented Oct 14, 2015

Test build #43706 has finished for PR 9112 at commit 48b352d.

  • This patch fails Spark unit tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@zsxwing
Copy link
Member

zsxwing commented Oct 14, 2015

Oh, NettyRpcHandlerSuite.receive tests the case that a remote client fires multiple connections. You can remove L45 and L46 here:

when(channel.remoteAddress()).thenReturn(new InetSocketAddress("localhost", 40001))

@SparkQA
Copy link

SparkQA commented Oct 14, 2015

Test build #43723 has finished for PR 9112 at commit e105f3f.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@rxin
Copy link
Contributor Author

rxin commented Oct 14, 2015

Merging this .

@asfgit asfgit closed this in cf2e0ae Oct 14, 2015
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants