File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
yarn/src/test/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -41,7 +41,7 @@ import org.apache.spark.util.Utils
4141/**
4242 * Integration test for the external shuffle service with a yarn mini-cluster
4343 */
44- class ExternalShuffleSuite extends BaseYarnClusterSuite {
44+ class YarnExternalShuffleSuite extends BaseYarnClusterSuite {
4545
4646 override def yarnConfig : YarnConfiguration = {
4747 val yarnConfig = new YarnConfiguration ()
@@ -55,15 +55,15 @@ class ExternalShuffleSuite extends BaseYarnClusterSuite {
5555 val result = File .createTempFile(" result" , null , tempDir)
5656 runSpark(
5757 false ,
58- mainClassName(ExternalShuffleDriver .getClass),
58+ mainClassName(YarnExternalShuffleDriver .getClass),
5959 appArgs = Seq (result.getAbsolutePath()),
6060 extraConf = Map (" spark.shuffle.service.enabled" -> " true" )
6161 )
6262 checkResult(result)
6363 }
6464}
6565
66- private object ExternalShuffleDriver extends Logging with Matchers {
66+ private object YarnExternalShuffleDriver extends Logging with Matchers {
6767
6868 val WAIT_TIMEOUT_MILLIS = 10000
6969
You can’t perform that action at this time.
0 commit comments