Skip to content

Commit cdb7d82

Browse files
authored
Merge pull request #18 from zavoraad/master
upgrade to spark 3.4.1
2 parents 1f91d24 + e8c5512 commit cdb7d82

File tree

4 files changed

+2
-38
lines changed

4 files changed

+2
-38
lines changed

build.sbt

Lines changed: 1 addition & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import sbt.nio.Keys._
1010
lazy val scala212 = "2.12.8"
1111
lazy val scala211 = "2.11.12"
1212

13-
lazy val sparkVersion = sys.env.getOrElse("SPARK_VERSION", "3.2.1")
13+
lazy val sparkVersion = sys.env.getOrElse("SPARK_VERSION", "3.4.1")
1414

1515
def majorMinorVersion(version: String): String = {
1616
StringUtils.ordinalIndexOf(version, ".", 2) match {
@@ -79,9 +79,6 @@ lazy val commonSettings = Seq(
7979
resolvers += "Apache Snapshots" at "https://repository.apache.org/snapshots/"
8080
)
8181

82-
lazy val functionsYml = settingKey[File]("functionsYml")
83-
ThisBuild / functionsYml := (ThisBuild / baseDirectory).value / "functions.yml"
84-
8582
lazy val sparkDependencies = Seq(
8683
"org.apache.spark" %% "spark-catalyst" % sparkVersion,
8784
"org.apache.spark" %% "spark-core" % sparkVersion,
@@ -134,7 +131,6 @@ lazy val core = (project in file("."))
134131
// do so.
135132
Compile / packageBin / packageOptions +=
136133
Package.ManifestAttributes("Git-Release-Hash" -> currentGitHash(baseDirectory.value)),
137-
bintrayRepository := "smolder",
138134
libraryDependencies ++= coreDependencies :+ scalaLoggingDependency.value,
139135
Compile / unmanagedSourceDirectories +=
140136
baseDirectory.value / "src" / "main" / "shim" / majorMinorVersion(sparkVersion),
@@ -179,29 +175,6 @@ ThisBuild / pomIncludeRepository := { _ =>
179175
ThisBuild / publishMavenStyle := true
180176

181177
ThisBuild / bintrayOrganization := Some("com.databricks.labs")
182-
ThisBuild / bintrayRepository := "smolder"
183-
184-
lazy val stableVersion = settingKey[String]("Stable version")
185-
ThisBuild / stableVersion := IO
186-
.read((ThisBuild / baseDirectory).value / "stable-version.txt")
187-
.trim()
188-
189-
lazy val stagedRelease = (project in file("src/test"))
190-
.settings(
191-
commonSettings,
192-
Test / resourceDirectory := baseDirectory.value / "resources",
193-
Test / scalaSource := baseDirectory.value / "scala",
194-
Test / unmanagedSourceDirectories += baseDirectory.value / "shim" / majorMinorVersion(sparkVersion),
195-
libraryDependencies ++= testSparkDependencies ++ testCoreDependencies :+
196-
"com.databricks.labs" %% "smolder" % stableVersion.value % "test",
197-
resolvers := Seq("bintray-staging" at "https://dl.bintray.com/com.databricks.labs/smolder"),
198-
org
199-
.jetbrains
200-
.sbt
201-
.extractors
202-
.SettingKeys
203-
.sbtIdeaIgnoreModule := true // Do not import this SBT project into IDEA
204-
)
205178

206179
import ReleaseTransformations._
207180

@@ -231,7 +204,6 @@ releaseProcess := Seq[ReleaseStep](
231204
tagRelease
232205
) ++
233206
crossReleaseStep(publishArtifacts) ++
234-
crossReleaseStep(releaseStepCommandAndRemaining("stagedRelease/test")) ++
235207
Seq(
236208
setNextVersion,
237209
commitNextVersion

project/StableVersionPlugin.scala

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -35,13 +35,6 @@ object StableVersionPlugin extends AutoPlugin {
3535

3636
import autoImport._
3737

38-
override def projectSettings: Seq[Setting[_]] = {
39-
Seq(
40-
stableVersionFile := baseDirectory.value / "stable-version.txt",
41-
stableCommitMessage := s"Setting stable version to ${runtimeVersion.value}"
42-
)
43-
}
44-
4538
private def updateStableVersionStep(
4639
selectVersion: Versions => String,
4740
fileSettingKey: SettingKey[File]): ReleaseStep = { st: State =>

src/main/scala/com/databricks/labs/smolder/HL7FileFormat.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ class HL7FileFormat extends FileFormat with DataSourceRegister {
7373
val serializableConf = new SerializableConfiguration(hadoopConf)
7474

7575
partitionedFile => {
76-
val path = new Path(partitionedFile.filePath)
76+
val path = new Path(partitionedFile.filePath.toUri)
7777
val hadoopFs = path.getFileSystem(serializableConf.value)
7878

7979
// open file, read fully, and close

version.sbt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +0,0 @@
1-
version in ThisBuild := "0.0.3-SNAPSHOT"

0 commit comments

Comments
 (0)