From 039dd62e1689cf286042cfca16278786ae6453e1 Mon Sep 17 00:00:00 2001 From: Chandni Singh Date: Sun, 20 Jun 2021 23:05:32 -0700 Subject: [PATCH] Removed the reference to spark.shuffle.push.based.enabled --- .../org/apache/spark/shuffle/ShuffleBlockPusherSuite.scala | 2 -- 1 file changed, 2 deletions(-) diff --git a/core/src/test/scala/org/apache/spark/shuffle/ShuffleBlockPusherSuite.scala b/core/src/test/scala/org/apache/spark/shuffle/ShuffleBlockPusherSuite.scala index 4e51ba4b3a2a..de6a2c939177 100644 --- a/core/src/test/scala/org/apache/spark/shuffle/ShuffleBlockPusherSuite.scala +++ b/core/src/test/scala/org/apache/spark/shuffle/ShuffleBlockPusherSuite.scala @@ -56,8 +56,6 @@ class ShuffleBlockPusherSuite extends SparkFunSuite with BeforeAndAfterEach { when(dependency.partitioner).thenReturn(new HashPartitioner(8)) when(dependency.serializer).thenReturn(new JavaSerializer(conf)) when(dependency.getMergerLocs).thenReturn(Seq(BlockManagerId("test-client", "test-client", 1))) - conf.set("spark.shuffle.push.based.enabled", "true") - conf.set("spark.shuffle.service.enabled", "true") // Set the env because the shuffler writer gets the shuffle client instance from the env. val mockEnv = mock(classOf[SparkEnv]) when(mockEnv.conf).thenReturn(conf)