-
- Downloads
[SPARK-2938] Support SASL authentication in NettyBlockTransferService
Also lays the groundwork for supporting it inside the external shuffle service. Author: Aaron Davidson <aaron@databricks.com> Closes #3087 from aarondav/sasl and squashes the following commits: 3481718 [Aaron Davidson] Delete rogue println 44f8410 [Aaron Davidson] Delete documentation - muahaha! eb9f065 [Aaron Davidson] Improve documentation and add end-to-end test at Spark-level a6b95f1 [Aaron Davidson] Address comments 785bbde [Aaron Davidson] Cleanup 79973cb [Aaron Davidson] Remove unused file 151b3c5 [Aaron Davidson] Add docs, timeout config, better failure handling f6177d7 [Aaron Davidson] Cleanup SASL state upon connection termination 7b42adb [Aaron Davidson] Add unit tests 8191bcb [Aaron Davidson] [SPARK-2938] Support SASL authentication in NettyBlockTransferService
Showing
- core/src/main/scala/org/apache/spark/SecurityManager.scala 20 additions, 3 deletionscore/src/main/scala/org/apache/spark/SecurityManager.scala
- core/src/main/scala/org/apache/spark/SparkConf.scala 6 additions, 0 deletionscore/src/main/scala/org/apache/spark/SparkConf.scala
- core/src/main/scala/org/apache/spark/SparkContext.scala 2 additions, 0 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/SparkEnv.scala 2 additions, 1 deletioncore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/SparkSaslClient.scala 0 additions, 147 deletionscore/src/main/scala/org/apache/spark/SparkSaslClient.scala
- core/src/main/scala/org/apache/spark/executor/Executor.scala 1 addition, 0 deletionscore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala 21 additions, 7 deletions...pache/spark/network/netty/NettyBlockTransferService.scala
- core/src/main/scala/org/apache/spark/network/nio/Connection.scala 3 additions, 2 deletions.../main/scala/org/apache/spark/network/nio/Connection.scala
- core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala 4 additions, 3 deletions...cala/org/apache/spark/network/nio/ConnectionManager.scala
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 29 additions, 16 deletions...rc/main/scala/org/apache/spark/storage/BlockManager.scala
- core/src/test/scala/org/apache/spark/network/netty/NettyBlockTransferSecuritySuite.scala 161 additions, 0 deletions...spark/network/netty/NettyBlockTransferSecuritySuite.scala
- core/src/test/scala/org/apache/spark/network/nio/ConnectionManagerSuite.scala 3 additions, 3 deletions...org/apache/spark/network/nio/ConnectionManagerSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerReplicationSuite.scala 2 additions, 0 deletions...g/apache/spark/storage/BlockManagerReplicationSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala 3 additions, 1 deletion...st/scala/org/apache/spark/storage/BlockManagerSuite.scala
- docs/security.md 0 additions, 1 deletiondocs/security.md
- network/common/src/main/java/org/apache/spark/network/TransportContext.java 14 additions, 1 deletion.../main/java/org/apache/spark/network/TransportContext.java
- network/common/src/main/java/org/apache/spark/network/client/TransportClient.java 9 additions, 2 deletions...java/org/apache/spark/network/client/TransportClient.java
- network/common/src/main/java/org/apache/spark/network/client/TransportClientBootstrap.java 32 additions, 0 deletions...apache/spark/network/client/TransportClientBootstrap.java
- network/common/src/main/java/org/apache/spark/network/client/TransportClientFactory.java 50 additions, 14 deletions...g/apache/spark/network/client/TransportClientFactory.java
- network/common/src/main/java/org/apache/spark/network/server/NoOpRpcHandler.java 1 addition, 1 deletion.../java/org/apache/spark/network/server/NoOpRpcHandler.java
Loading
Please register or sign in to comment