Skip to content
Snippets Groups Projects
Commit 48854e1d authored by Mridul Muralidharan's avatar Mridul Muralidharan
Browse files

If key is not valid, close connection

parent e46d547c
No related branches found
No related tags found
No related merge requests found
......@@ -29,8 +29,6 @@ project/build/target/
project/plugins/target/
project/plugins/lib_managed/
project/plugins/src_managed/
logs/
log/
spark-tests.log
streaming-tests.log
dependency-reduced-pom.xml
......
......@@ -281,6 +281,9 @@ private[spark] class ConnectionManager(port: Int) extends Logging {
if (key.isWritable) {
triggerWrite(key)
}
} else {
logInfo("Key not valid ? " + key)
throw new CancelledKeyException()
}
} catch {
// weird, but we saw this happening - even though key.isValid was true, key.isAcceptable would throw CancelledKeyException.
......
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