diff options
| author | Xiangrui Meng <meng@databricks.com> | 2015-09-24 08:25:44 -0700 |
|---|---|---|
| committer | Xiangrui Meng <meng@databricks.com> | 2015-09-24 08:25:44 -0700 |
| commit | 02144d6745ec0a6d8877d969feb82139bd22437f (patch) | |
| tree | 78c8b59523a2c8d51a9bfcfc1b337d80c647a2f8 /network | |
| parent | d91967e159f416924bbd7f0db25156588d4bd7b1 (diff) | |
| download | spark-02144d6745ec0a6d8877d969feb82139bd22437f.tar.gz spark-02144d6745ec0a6d8877d969feb82139bd22437f.tar.bz2 spark-02144d6745ec0a6d8877d969feb82139bd22437f.zip | |
Revert "[SPARK-6028][Core]A new RPC implemetation based on the network module"
This reverts commit 084e4e126211d74a79e8dbd2d0e604dd3c650822.
Diffstat (limited to 'network')
3 files changed, 0 insertions, 7 deletions
diff --git a/network/common/src/main/java/org/apache/spark/network/client/TransportClient.java b/network/common/src/main/java/org/apache/spark/network/client/TransportClient.java index fbb8bb6b2f..df841288a0 100644 --- a/network/common/src/main/java/org/apache/spark/network/client/TransportClient.java +++ b/network/common/src/main/java/org/apache/spark/network/client/TransportClient.java @@ -78,10 +78,6 @@ public class TransportClient implements Closeable { this.handler = Preconditions.checkNotNull(handler); } - public Channel getChannel() { - return channel; - } - public boolean isActive() { return channel.isOpen() || channel.isActive(); } diff --git a/network/common/src/main/java/org/apache/spark/network/server/RpcHandler.java b/network/common/src/main/java/org/apache/spark/network/server/RpcHandler.java index dbb7f95f55..2ba92a40f8 100644 --- a/network/common/src/main/java/org/apache/spark/network/server/RpcHandler.java +++ b/network/common/src/main/java/org/apache/spark/network/server/RpcHandler.java @@ -52,6 +52,4 @@ public abstract class RpcHandler { * No further requests will come from this client. */ public void connectionTerminated(TransportClient client) { } - - public void exceptionCaught(Throwable cause, TransportClient client) { } } diff --git a/network/common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java b/network/common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java index 96941d26be..df60278058 100644 --- a/network/common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java +++ b/network/common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java @@ -71,7 +71,6 @@ public class TransportRequestHandler extends MessageHandler<RequestMessage> { @Override public void exceptionCaught(Throwable cause) { - rpcHandler.exceptionCaught(cause, reverseClient); } @Override |