Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21346#discussion_r191002520
--- Diff:
common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java
---
@@ -193,10 +299,78 @@ public void sendOneWayMessage() throws Exception {
}
}
+ @Test
+ public void sendRpcWithStreamOneAtATime() throws Exception {
+ for (String stream: StreamTestHelper.STREAMS) {
--- End diff --
space before `:`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
