-
- Downloads
[SPARK-8873] [MESOS] Clean up shuffle files if external shuffle service is used
This patch builds directly on #7820, which is largely written by tnachen. The only addition is one commit for cleaning up the code. There should be no functional differences between this and #7820. Author: Timothy Chen <tnachen@gmail.com> Author: Andrew Or <andrew@databricks.com> Closes #7881 from andrewor14/tim-cleanup-mesos-shuffle and squashes the following commits: 8894f7d [Andrew Or] Clean up code 2a5fa10 [Andrew Or] Merge branch 'mesos_shuffle_clean' of github.com:tnachen/spark into tim-cleanup-mesos-shuffle fadff89 [Timothy Chen] Address comments. e4d0f1d [Timothy Chen] Clean up external shuffle data on driver exit with Mesos.
Showing
- core/src/main/scala/org/apache/spark/SparkContext.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/deploy/ExternalShuffleService.scala 15 additions, 2 deletions...cala/org/apache/spark/deploy/ExternalShuffleService.scala
- core/src/main/scala/org/apache/spark/deploy/mesos/MesosExternalShuffleService.scala 107 additions, 0 deletions...ache/spark/deploy/mesos/MesosExternalShuffleService.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala 3 additions, 3 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala 49 additions, 3 deletions...scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala
- core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala 3 additions, 2 deletions...uler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala
- launcher/src/main/java/org/apache/spark/launcher/SparkClassCommandBuilder.java 2 additions, 1 deletion...a/org/apache/spark/launcher/SparkClassCommandBuilder.java
- network/common/src/main/java/org/apache/spark/network/client/TransportClient.java 5 additions, 0 deletions...java/org/apache/spark/network/client/TransportClient.java
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java 6 additions, 0 deletions...he/spark/network/shuffle/ExternalShuffleBlockHandler.java
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleClient.java 8 additions, 4 deletions...g/apache/spark/network/shuffle/ExternalShuffleClient.java
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/mesos/MesosExternalShuffleClient.java 72 additions, 0 deletions...ark/network/shuffle/mesos/MesosExternalShuffleClient.java
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlockTransferMessage.java 3 additions, 1 deletion.../spark/network/shuffle/protocol/BlockTransferMessage.java
- network/shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/mesos/RegisterDriver.java 60 additions, 0 deletions.../spark/network/shuffle/protocol/mesos/RegisterDriver.java
- sbin/start-mesos-shuffle-service.sh 35 additions, 0 deletionssbin/start-mesos-shuffle-service.sh
- sbin/stop-mesos-shuffle-service.sh 25 additions, 0 deletionssbin/stop-mesos-shuffle-service.sh
Loading
Please register or sign in to comment