Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21346#discussion_r191001378
--- Diff:
common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java
---
@@ -85,10 +96,52 @@ public void receive(TransportClient client, ByteBuffer
message) {
oneWayMsgs = new ArrayList<>();
}
+ private static void receiveStream(String msg, StreamData streamData) {
+ try {
+ if (msg.startsWith("fail/")) {
+ String[] parts = msg.split("/");
+ switch(parts[1]) {
--- End diff --
space before `(`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
