From ec09acdd4a72333e1c9c2e9d8e12e9c4c07770c8 Mon Sep 17 00:00:00 2001
From: witgo <witgo@qq.com>
Date: Tue, 6 May 2014 14:17:39 -0700
Subject: [PATCH] SPARK-1734: spark-submit throws an exception: Exception in
thread "main"...
... java.lang.ClassNotFoundException: org.apache.spark.broadcast.TorrentBroadcastFactory
Author: witgo <witgo@qq.com>
Closes #665 from witgo/SPARK-1734 and squashes the following commits:
cacf238 [witgo] SPARK-1734: spark-submit throws an exception: Exception in thread "main" java.lang.ClassNotFoundException: org.apache.spark.broadcast.TorrentBroadcastFactory
---
.../scala/org/apache/spark/deploy/SparkSubmitArguments.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala b/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala
index 45defb9a3f..7031cdd9b4 100644
--- a/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala
@@ -333,6 +333,6 @@ object SparkSubmitArguments {
val message = s"Failed when loading Spark properties file ${file.getName}"
throw new SparkException(message, e)
}
- properties.stringPropertyNames().toSeq.map(k => (k, properties(k)))
+ properties.stringPropertyNames().toSeq.map(k => (k, properties(k).trim))
}
}
--
GitLab