Repository: spark
Updated Branches:
  refs/heads/master be72b157e -> 3ed1ae100


[SPARK-20641][CORE] Add missing kvstore module in Laucher and SparkSubmit code

There're two code in Launcher and SparkSubmit will will explicitly list all the 
Spark submodules, newly added kvstore module is missing in this two parts, so 
submitting a minor PR to fix this.

Author: jerryshao <[email protected]>

Closes #19014 from jerryshao/missing-kvstore.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/3ed1ae10
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/3ed1ae10
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/3ed1ae10

Branch: refs/heads/master
Commit: 3ed1ae10052e456d4efb13b2e51b5a43f7b1609a
Parents: be72b15
Author: jerryshao <[email protected]>
Authored: Tue Aug 22 10:14:41 2017 -0700
Committer: Marcelo Vanzin <[email protected]>
Committed: Tue Aug 22 10:14:45 2017 -0700

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala      | 2 +-
 .../java/org/apache/spark/launcher/AbstractCommandBuilder.java     | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/3ed1ae10/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala 
b/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala
index e7e8fbc..e569251 100644
--- a/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala
@@ -988,7 +988,7 @@ private[spark] object SparkSubmitUtils {
   // We need to specify each component explicitly, otherwise we miss 
spark-streaming-kafka-0-8 and
   // other spark-streaming utility components. Underscore is there to 
differentiate between
   // spark-streaming_2.1x and spark-streaming-kafka-0-8-assembly_2.1x
-  val IVY_DEFAULT_EXCLUDES = Seq("catalyst_", "core_", "graphx_", "launcher_", 
"mllib_",
+  val IVY_DEFAULT_EXCLUDES = Seq("catalyst_", "core_", "graphx_", "kvstore_", 
"launcher_", "mllib_",
     "mllib-local_", "network-common_", "network-shuffle_", "repl_", "sketch_", 
"sql_", "streaming_",
     "tags_", "unsafe_")
 

http://git-wip-us.apache.org/repos/asf/spark/blob/3ed1ae10/launcher/src/main/java/org/apache/spark/launcher/AbstractCommandBuilder.java
----------------------------------------------------------------------
diff --git 
a/launcher/src/main/java/org/apache/spark/launcher/AbstractCommandBuilder.java 
b/launcher/src/main/java/org/apache/spark/launcher/AbstractCommandBuilder.java
index 44028c5..c32974a 100644
--- 
a/launcher/src/main/java/org/apache/spark/launcher/AbstractCommandBuilder.java
+++ 
b/launcher/src/main/java/org/apache/spark/launcher/AbstractCommandBuilder.java
@@ -144,6 +144,7 @@ abstract class AbstractCommandBuilder {
     if (prependClasses || isTesting) {
       String scala = getScalaVersion();
       List<String> projects = Arrays.asList(
+        "common/kvstore",
         "common/network-common",
         "common/network-shuffle",
         "common/network-yarn",


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to