Renamed isPushBasedShuffleEnabled to isPushShuffleEnabled and fixed the comment

Author: otterc

core/src/main/scala/org/apache/spark/shuffle/ShuffleWriteProcessor.scala

@@ -64,7 +64,7 @@ private[spark] class ShuffleWriteProcessor extends Serializable with Logging {
         // The map task only takes care of converting the shuffle data file into multiple
         // block push requests and pushing the first batch of blocks to the remote shuffle
         // service. The remaining block pushes is handled by netty client threads.
-        if (Utils.isPushBasedShuffleEnabled(SparkEnv.get.conf) && dep.getMergerLocs.nonEmpty) {
+        if (Utils.isPushShuffleEnabled(SparkEnv.get.conf) && dep.getMergerLocs.nonEmpty) {
           writer.initiateBlockPush(
             manager.shuffleBlockResolver.asInstanceOf[IndexShuffleBlockResolver],
             writer.getPartitionLengths(), dep, partition.index, mapId, SparkEnv.get.conf)

core/src/main/scala/org/apache/spark/shuffle/ShuffleWriter.scala

@@ -461,7 +461,7 @@ private[spark] object ShuffleWriter {
 
   private val BLOCK_PUSHER_POOL: ExecutorService = {
     val conf = SparkEnv.get.conf
-    if (Utils.isPushBasedShuffleEnabled(conf)) {
+    if (Utils.isPushShuffleEnabled(conf)) {
       val numThreads = conf.get(PUSH_SHUFFLE_NUM_PUSH_THREADS)
         .getOrElse(conf.getInt(SparkLauncher.EXECUTOR_CORES, 1))
       ThreadUtils.newDaemonFixedThreadPool(numThreads, "block-push-thread")

core/src/main/scala/org/apache/spark/util/Utils.scala

@@ -2543,10 +2543,8 @@ private[spark] object Utils extends Logging {
 
   /**
    * Push based shuffle can only be enabled when external shuffle service is enabled.
-   * In the initial version, we cannot support pushed based shuffle and adaptive execution
-   * at the same time. Will improve this in a later version.
    */
-  def isPushBasedShuffleEnabled(conf: SparkConf): Boolean = {
+  def isPushShuffleEnabled(conf: SparkConf): Boolean = {
     conf.get(PUSH_SHUFFLE_ENABLED) && conf.get(SHUFFLE_SERVICE_ENABLED)
   }