diff options
author | Lianhui Wang <lianhuiwang09@gmail.com> | 2016-04-25 12:33:32 -0700 |
---|---|---|
committer | Marcelo Vanzin <vanzin@cloudera.com> | 2016-04-25 12:33:32 -0700 |
commit | 6bfe42a3be4fbf8bc6f93a4709038fda8ad0610b (patch) | |
tree | d98096dd1f3cba95289ed51a2f65accc38e6d7e4 /core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala | |
parent | 425f6916462ca5d0595c61101d52686006ed6b8b (diff) | |
download | spark-6bfe42a3be4fbf8bc6f93a4709038fda8ad0610b.tar.gz spark-6bfe42a3be4fbf8bc6f93a4709038fda8ad0610b.tar.bz2 spark-6bfe42a3be4fbf8bc6f93a4709038fda8ad0610b.zip |
[SPARK-14731][shuffle]Revert SPARK-12130 to make 2.0 shuffle service compatible with 1.x
## What changes were proposed in this pull request?
SPARK-12130 make 2.0 shuffle service incompatible with 1.x. So from discussion: [http://apache-spark-developers-list.1001551.n3.nabble.com/YARN-Shuffle-service-and-its-compatibility-td17222.html](url) we should maintain compatibility between Spark 1.x and Spark 2.x's shuffle service.
I put string comparison into executor's register at first avoid string comparison in getBlockData every time.
## How was this patch tested?
N/A
Author: Lianhui Wang <lianhuiwang09@gmail.com>
Closes #12568 from lianhuiwang/SPARK-14731.
Diffstat (limited to 'core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala')
-rw-r--r-- | core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala b/core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala index 364fad664e..4ea8a7120a 100644 --- a/core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala +++ b/core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala @@ -29,9 +29,6 @@ import org.apache.spark.{ShuffleDependency, TaskContext} */ private[spark] trait ShuffleManager { - /** Return short name for the ShuffleManager */ - val shortName: String - /** * Register a shuffle with the manager and obtain a handle for it to pass to tasks. */ |