Skip to content

Commit

Permalink
[FEA] Profiler autotuner should only specify standard Spark versions …
Browse files Browse the repository at this point in the history
…for shuffle manager setting

Signed-off-by: Kuhu Shukla <[email protected]>
  • Loading branch information
kuhushukla committed Nov 16, 2023
1 parent 7559d63 commit a13d43d
Showing 1 changed file with 13 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -597,9 +597,19 @@ class AutoTuner(
}

def calculateJobLevelRecommendations(): Unit = {
val shuffleManagerVersion = appInfoProvider.getSparkVersion.get.filterNot("().".toSet)
appendRecommendation("spark.shuffle.manager",
"com.nvidia.spark.rapids.spark" + shuffleManagerVersion + ".RapidsShuffleManager")
val finalShuffleVersion = if (platform.contains("databricks")) {
val dbVersion = appInfoProvider.getProperty(
"spark.databricks.clusterUsageTags.sparkVersion").getOrElse("")
if (dbVersion.contains("10.4")) {
"321db"
} else if (dbVersion.contains("11.3")) {
"330db"
} else {
"332db"
}
} else shuffleManagerVersion
appendRecommendation("spark.shuffle.manager",
"com.nvidia.spark.rapids.spark" + finalShuffleVersion + ".RapidsShuffleManager")
appendComment(classPathComments("rapids.shuffle.jars"))

recommendFileCache()
Expand Down

0 comments on commit a13d43d

Please sign in to comment.