-
- Downloads
[SPARK-4242] [Core] Add SASL to external shuffle service
Does three things: (1) Adds SASL to ExternalShuffleClient, (2) puts SecurityManager in BlockManager's constructor, and (3) adds unit test. Author: Aaron Davidson <aaron@databricks.com> Closes #3108 from aarondav/sasl-client and squashes the following commits: 48b622d [Aaron Davidson] Screw it, let's just get LimitedInputStream 3543b70 [Aaron Davidson] Back out of pom change due to unknown test issue? b58518a [Aaron Davidson] ByteStreams.limit() not available :( cbe451a [Aaron Davidson] Address comments 2bf2908 [Aaron Davidson] [SPARK-4242] [Core] Add SASL to external shuffle service
Showing
- LICENSE 20 additions, 1 deletionLICENSE
- core/src/main/scala/org/apache/spark/SparkEnv.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 7 additions, 5 deletions...rc/main/scala/org/apache/spark/storage/BlockManager.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerReplicationSuite.scala 2 additions, 2 deletions...g/apache/spark/storage/BlockManagerReplicationSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala 2 additions, 2 deletions...st/scala/org/apache/spark/storage/BlockManagerSuite.scala
- network/common/pom.xml 1 addition, 0 deletionsnetwork/common/pom.xml
- network/common/src/main/java/org/apache/spark/network/buffer/FileSegmentManagedBuffer.java 2 additions, 1 deletion...apache/spark/network/buffer/FileSegmentManagedBuffer.java
- network/common/src/main/java/org/apache/spark/network/util/LimitedInputStream.java 87 additions, 0 deletions...ava/org/apache/spark/network/util/LimitedInputStream.java
- network/shuffle/pom.xml 1 addition, 0 deletionsnetwork/shuffle/pom.xml
- network/shuffle/src/main/java/org/apache/spark/network/sasl/SparkSaslClient.java 0 additions, 1 deletion...n/java/org/apache/spark/network/sasl/SparkSaslClient.java
- network/shuffle/src/main/java/org/apache/spark/network/sasl/SparkSaslServer.java 6 additions, 3 deletions...n/java/org/apache/spark/network/sasl/SparkSaslServer.java
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleClient.java 27 additions, 4 deletions...g/apache/spark/network/shuffle/ExternalShuffleClient.java
- network/shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleIntegrationSuite.java 2 additions, 2 deletions...park/network/shuffle/ExternalShuffleIntegrationSuite.java
- network/shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleSecuritySuite.java 113 additions, 0 deletions...e/spark/network/shuffle/ExternalShuffleSecuritySuite.java
- streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala 1 addition, 1 deletion...rg/apache/spark/streaming/ReceivedBlockHandlerSuite.scala
Loading
Please register or sign in to comment