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 1ac41ec6aac0f..e3d187d78a5d5 100644 --- a/core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala +++ b/core/src/main/scala/org/apache/spark/shuffle/ShuffleManager.scala @@ -61,7 +61,7 @@ private[spark] trait ShuffleManager { def shuffleBlockResolver: ShuffleBlockResolver /** Return short name for the ShuffleManager */ - def shortShuffleMgrName: String + val shortShuffleMgrName: String /** Shut down this ShuffleManager. */ def stop(): Unit diff --git a/core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleManager.scala b/core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleManager.scala index edae8f76f6c67..a836125026aee 100644 --- a/core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleManager.scala +++ b/core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleManager.scala @@ -71,7 +71,7 @@ private[spark] class HashShuffleManager(conf: SparkConf) extends ShuffleManager fileShuffleBlockResolver } - override def shortShuffleMgrName: String = "hash" + override val shortShuffleMgrName: String = "hash" /** Shut down this ShuffleManager. */ override def stop(): Unit = { diff --git a/core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleManager.scala b/core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleManager.scala index 4cd2ef3fdc637..628e5269a0b1d 100644 --- a/core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleManager.scala +++ b/core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleManager.scala @@ -160,7 +160,7 @@ private[spark] class SortShuffleManager(conf: SparkConf) extends ShuffleManager true } - override def shortShuffleMgrName: String = "sort" + override val shortShuffleMgrName: String = "sort" /** Shut down this ShuffleManager. */ override def stop(): Unit = {