Skip to content

Commit

Permalink
issue #827 Scala 2.11 compatibility
Browse files Browse the repository at this point in the history
  • Loading branch information
wajda committed Sep 8, 2024
1 parent 5a9ebdb commit 9479998
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ class ElasticSearchSpec
val esOptions = Map(
"es.nodes" -> esNodes,
"es.port" -> esPort.toString,
"es.nodes.wan.only" -> "true",
"es.nodes.wan.only" -> "true"
)

withNewSparkSession(implicit spark => {
Expand Down Expand Up @@ -106,7 +106,7 @@ class ElasticSearchSpec
"es.nodes" -> esNodes,
"es.port" -> esPort.toString,
"es.nodes.wan.only" -> "true",
"es.resource" -> s"$index/$docType",
"es.resource" -> s"$index/$docType"
)

withNewSparkSession(implicit spark => {
Expand Down

0 comments on commit 9479998

Please sign in to comment.