Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
bowenliang123 committed Aug 29, 2023
1 parent 7d4cc13 commit daa6742
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -103,14 +103,14 @@ class SparkProcessBuilder(
}

override val jarName: String = {
val sparkCoreScalaVersion = {
val sparkCoreScalaVersion: String = {
Paths.get(sparkHome, "jars").toFile.list((_: File, name: String) => {
name.startsWith("spark-core_") && name.endsWith(".jar")
}).map(p => {
p.substring(p.indexOf("_") + 1, p.lastIndexOf("-"))
}).headOption match {
case Some(scalaVersion) => scalaVersion
case None => scalaRuntimeSemanticVersion
case None => scalaRuntimeSemanticVersion.toString
}
}
s"${module}_$sparkCoreScalaVersion-$KYUUBI_VERSION.jar"
Expand Down

0 comments on commit daa6742

Please sign in to comment.