Merge pull request #503 from pwendell/bug-fix

createNewSparkContext should use sparkHome/jars/environment.

Merge pull request #503 from pwendell/bug-fix
4223be3a · Matei Zaharia · 5d7b591c · 284ba909 · 4223be3a
Commit 4223be3a authored 12 years ago by Matei Zaharia
--- a/streaming/src/main/scala/spark/streaming/StreamingContext.scala
+++ b/streaming/src/main/scala/spark/streaming/StreamingContext.scala
@@ -505,7 +505,7 @@ object StreamingContext {
    if (MetadataCleaner.getDelaySeconds < 0) {
      MetadataCleaner.setDelaySeconds(3600)
    }
-    new SparkContext(master, appName)
+    new SparkContext(master, appName, sparkHome, jars, environment)
  }

  protected[streaming] def rddToFileName[T](prefix: String, suffix: String, time: Time): String = {