From bc95fe08dff62a0abea314ab4ab9275c8f119598 Mon Sep 17 00:00:00 2001
From: GuoQiang Li <witgo@qq.com>
Date: Sat, 16 Aug 2014 20:05:55 -0700
Subject: [PATCH] In the stop method of ConnectionManager to cancel the
ackTimeoutMonitor
cc JoshRosen sarutak
Author: GuoQiang Li <witgo@qq.com>
Closes #1989 from witgo/cancel_ackTimeoutMonitor and squashes the following commits:
4a700fa [GuoQiang Li] In the stop method of ConnectionManager to cancel the ackTimeoutMonitor
---
.../main/scala/org/apache/spark/network/ConnectionManager.scala | 1 +
1 file changed, 1 insertion(+)
diff --git a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
index 37d69a9ec4..e77d762bdf 100644
--- a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
+++ b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
@@ -886,6 +886,7 @@ private[spark] class ConnectionManager(
}
def stop() {
+ ackTimeoutMonitor.cancel()
selectorThread.interrupt()
selectorThread.join()
selector.close()
--
GitLab