diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-02-25 19:40:52 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-02-25 19:40:52 -0800 |
| commit | 284ba90958df2d6efc08e3f8381bb9ef09f8b322 (patch) | |
| tree | bf42ea89e464efa4f0f706184ea5bc4dccf0bef2 /streaming | |
| parent | 7b8853493248f4b2855a548facc407a3db939ba0 (diff) | |
| download | spark-284ba90958df2d6efc08e3f8381bb9ef09f8b322.tar.gz spark-284ba90958df2d6efc08e3f8381bb9ef09f8b322.tar.bz2 spark-284ba90958df2d6efc08e3f8381bb9ef09f8b322.zip | |
createNewSparkContext should use sparkHome/jars/environment.
This fixes a bug introduced by Matei's recent change.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/StreamingContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/spark/streaming/StreamingContext.scala index 31b5d2c8bc..b8b60aab43 100644 --- 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 = { |