Skip to content

Commit 5a5ccb0

Browse files
committed
Merge pull request #164 from colorant/yarn-assembly
add spark-yarn dependency
2 parents d97984e + 5f84acc commit 5a5ccb0

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

project/SharkBuild.scala

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,12 @@ object SharkBuild extends Build {
4040
DEFAULT_HADOOP_VERSION
4141

4242

43+
// Whether to build Shark with Yarn support
44+
val YARN_ENABLED = scala.util.Properties.envOrNone("SHARK_YARN") match {
45+
case None => false
46+
case Some(v) => v.toBoolean
47+
}
48+
4349
// Whether to build Shark with Tachyon jar.
4450
val TACHYON_ENABLED = false
4551

@@ -123,6 +129,7 @@ object SharkBuild extends Build {
123129
"junit" % "junit" % "4.10" % "test",
124130
"net.java.dev.jets3t" % "jets3t" % "0.7.1",
125131
"com.novocode" % "junit-interface" % "0.8" % "test") ++
132+
(if (YARN_ENABLED) Some("org.apache.spark" %% "spark-yarn" % SPARK_VERSION) else None).toSeq ++
126133
(if (TACHYON_ENABLED) Some("org.tachyonproject" % "tachyon" % "0.3.0-SNAPSHOT" excludeAll(excludeKyro, excludeHadoop) ) else None).toSeq
127134
)
128135

@@ -135,6 +142,7 @@ object SharkBuild extends Build {
135142
mergeStrategy in assembly := {
136143
case m if m.toLowerCase.endsWith("manifest.mf") => MergeStrategy.discard
137144
case m if m.toLowerCase.matches("meta-inf.*\\.sf$") => MergeStrategy.discard
145+
case "META-INF/services/org.apache.hadoop.fs.FileSystem" => MergeStrategy.concat
138146
case "reference.conf" => MergeStrategy.concat
139147
case _ => MergeStrategy.first
140148
}

0 commit comments

Comments
 (0)