File tree Expand file tree Collapse file tree 3 files changed +10
-4
lines changed
Expand file tree Collapse file tree 3 files changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -181,7 +181,7 @@ echo "Spark $VERSION$GITREVSTRING built for Hadoop $SPARK_HADOOP_VERSION" > "$DI
181181# Copy jars
182182cp " $FWDIR " /assembly/target/scala* /* assembly* hadoop* .jar " $DISTDIR /lib/"
183183cp " $FWDIR " /examples/target/scala* /spark-examples* .jar " $DISTDIR /lib/"
184- cp " $FWDIR " /network/yarn/target/scala* /spark-network -yarn* .jar " $DISTDIR /lib/"
184+ cp " $FWDIR " /network/yarn/target/scala* /spark-* -yarn-shuffle .jar " $DISTDIR /lib/"
185185
186186# Copy example sources (needed for python and SQL)
187187mkdir -p " $DISTDIR /examples/src/main"
Original file line number Diff line number Diff line change 6060 <artifactId >maven-shade-plugin</artifactId >
6161 <configuration >
6262 <shadedArtifactAttached >false</shadedArtifactAttached >
63- <outputFile >${project.build.directory} /scala-${scala.binary.version} /spark-network-yarn- ${project.version} -hadoop ${hadoop.version} .jar</outputFile >
63+ <outputFile >${project.build.directory} /scala-${scala.binary.version} /spark-${project.version} -yarn-shuffle .jar</outputFile >
6464 <artifactSet >
6565 <includes >
6666 <include >*:*</include >
Original file line number Diff line number Diff line change @@ -270,8 +270,14 @@ object Assembly {
270270
271271 lazy val settings = assemblySettings ++ Seq (
272272 test in assembly := {},
273- jarName in assembly <<= (version, moduleName) map { (v, mName) => mName + " -" + v + " -hadoop" +
274- Option (System .getProperty(" hadoop.version" )).getOrElse(" 1.0.4" ) + " .jar" },
273+ jarName in assembly <<= (version, moduleName) map { (v, mName) =>
274+ if (mName.contains(" network-yarn" )) {
275+ // This must match the same name used in maven (see network/yarn/pom.xml)
276+ " spark-" + v + " -yarn-shuffle.jar"
277+ } else {
278+ mName + " -" + v + " -hadoop" + Option (System .getProperty(" hadoop.version" )).getOrElse(" 1.0.4" ) + " .jar"
279+ }
280+ },
275281 mergeStrategy in assembly := {
276282 case PathList (" org" , " datanucleus" , xs @ _* ) => MergeStrategy .discard
277283 case m if m.toLowerCase.endsWith(" manifest.mf" ) => MergeStrategy .discard
You can’t perform that action at this time.
0 commit comments