Skip to content

Commit

Permalink
all tests passing after spark3.2.1 upgrade
Browse files Browse the repository at this point in the history
  • Loading branch information
zavoraad committed Oct 31, 2022
1 parent fe32ab4 commit 6e0927c
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 5 deletions.
8 changes: 4 additions & 4 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -103,14 +103,14 @@ lazy val testCoreDependencies = Seq(
)

lazy val coreDependencies = (providedSparkDependencies ++ testCoreDependencies ++ Seq(
"log4j" % "log4j" % "1.2.17",
// "log4j" % "log4j" % "1.2.17",
"org.slf4j" % "slf4j-api" % "1.7.25",
"org.slf4j" % "slf4j-log4j12" % "1.7.25",
"org.jdbi" % "jdbi" % "2.63.1",
// Fix versions of libraries that are depended on multiple times
"org.apache.hadoop" % "hadoop-client" % "2.7.3",
"io.netty" % "netty" % "3.9.9.Final",
"io.netty" % "netty-all" % "4.1.17.Final",
"org.apache.hadoop" % "hadoop-client" % "3.3.1",
// "io.netty" % "netty" % "3.9.9.Final",
// "io.netty" % "netty-all" % "4.1.17.Final",
"org.yaml" % "snakeyaml" % "1.16"
)).map(_.exclude("com.google.code.findbugs", "jsr305"))

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,8 @@ abstract class SmolderBaseTest

protected implicit def spark: SparkSession = {
val session = SparkSession.builder()
.master("local[2]")
.master("local[2]")
.config("spark.driver.bindAddress","127.0.0.1") //Explicitly state this for Spark3.2.1
.getOrCreate()

SparkSession.setActiveSession(session)
Expand Down

0 comments on commit 6e0927c

Please sign in to comment.