Skip to content

Commit

Permalink
Avoid hardcode port number in YarnShuffleService test
Browse files Browse the repository at this point in the history
  • Loading branch information
jerryshao committed Aug 28, 2015
1 parent 2f99c37 commit bcb93a8
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@ class YarnShuffleServiceSuite extends SparkFunSuite with Matchers with BeforeAnd
yarnConfig.set(YarnConfiguration.NM_AUX_SERVICES, "spark_shuffle")
yarnConfig.set(YarnConfiguration.NM_AUX_SERVICE_FMT.format("spark_shuffle"),
classOf[YarnShuffleService].getCanonicalName)
yarnConfig.setInt("spark.shuffle.service.port", 0)

yarnConfig.get("yarn.nodemanager.local-dirs").split(",").foreach { dir =>
val d = new File(dir)
Expand Down

0 comments on commit bcb93a8

Please sign in to comment.