From 4d95a7a3bbcec7272c01938e8f99b8f6df3ed2ed Mon Sep 17 00:00:00 2001
From: hanghang <584620569@qq.com>
Date: Wed, 13 Dec 2017 19:53:18 +0800
Subject: [PATCH] change code

---
 .../main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala b/core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala
index f951591e02a5c..05d47284d99ea 100644
--- a/core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala
+++ b/core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala
@@ -645,7 +645,11 @@ private[netty] class NettyRpcHandler(
       client: TransportClient,
       message: ByteBuffer): Unit = {
     val messageToDispatch = internalReceive(client, message)
-    dispatcher.postOneWayMessage(messageToDispatch)
+    try {
+      dispatcher.postOneWayMessage(messageToDispatch)
+    } catch {
+      case e: RpcEnvStoppedException => logWarning(e.getMessage)
+    }
   }
 
   private def internalReceive(client: TransportClient, message: ByteBuffer): RequestMessage = {