Skip to content
Snippets Groups Projects
Commit 56fd34af authored by zsxwing's avatar zsxwing Committed by Josh Rosen
Browse files

[SPARK-3741] Add afterExecute for handleConnectExecutor

Sorry. I found that I forgot to add `afterExecute` for `handleConnectExecutor` in #2593.

Author: zsxwing <zsxwing@gmail.com>

Closes #2794 from zsxwing/SPARK-3741 and squashes the following commits:

a0bc4dd [zsxwing] Add afterExecute for handleConnectExecutor
parent e7f4ea8a
No related branches found
No related tags found
No related merge requests found
...@@ -117,7 +117,16 @@ private[nio] class ConnectionManager( ...@@ -117,7 +117,16 @@ private[nio] class ConnectionManager(
conf.getInt("spark.core.connection.connect.threads.max", 8), conf.getInt("spark.core.connection.connect.threads.max", 8),
conf.getInt("spark.core.connection.connect.threads.keepalive", 60), TimeUnit.SECONDS, conf.getInt("spark.core.connection.connect.threads.keepalive", 60), TimeUnit.SECONDS,
new LinkedBlockingDeque[Runnable](), new LinkedBlockingDeque[Runnable](),
Utils.namedThreadFactory("handle-connect-executor")) Utils.namedThreadFactory("handle-connect-executor")) {
override def afterExecute(r: Runnable, t: Throwable): Unit = {
super.afterExecute(r, t)
if (t != null && NonFatal(t)) {
logError("Error in handleConnectExecutor is not handled properly", t)
}
}
}
private val serverChannel = ServerSocketChannel.open() private val serverChannel = ServerSocketChannel.open()
// used to track the SendingConnections waiting to do SASL negotiation // used to track the SendingConnections waiting to do SASL negotiation
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment