- Jan 05, 2014
-
-
Tathagata Das authored
-
- Jan 04, 2014
-
-
Tathagata Das authored
-
- Jan 02, 2014
-
-
Tathagata Das authored
Added StreamingContext.getOrCreate to for automatic recovery, and added RecoverableNetworkWordCount example to use it.
-
- Dec 29, 2013
-
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
- Dec 27, 2013
-
-
Patrick Wendell authored
-
- Dec 26, 2013
-
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
Refactor DriverClient to be more Actor-based
-
Patrick Wendell authored
-
Patrick Wendell authored
-
- Dec 25, 2013
-
-
Aaron Davidson authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
- Dec 24, 2013
-
-
Patrick Wendell authored
Deduplicate Local and Cluster schedulers. The code in LocalScheduler/LocalTaskSetManager was nearly identical to the code in ClusterScheduler/ClusterTaskSetManager. The redundancy made making updating the schedulers unnecessarily painful and error- prone. This commit combines the two into a single TaskScheduler/ TaskSetManager. Unfortunately the diff makes this change look much more invasive than it is -- TaskScheduler.scala is only superficially changed (names updated, overrides removed) from the old ClusterScheduler.scala, and the same with TaskSetManager.scala. Thanks @rxin for suggesting this change!
-
Patrick Wendell authored
Clean up shuffle files once their metadata is gone Previously, we would only clean the in-memory metadata for consolidated shuffle files. Additionally, fixes a bug where the Metadata Cleaner was ignoring type-specific TTLs.
-
Kay Ousterhout authored
-
Matei Zaharia authored
Change the order of CLASSPATH. SPARK_TOOLS_JAR should be placed after CLASSPATH or at least after SPARK_CLASSPATH. If SPARK_TOOLS_JAR is placed before CLASSPATH, all assembled classes and resources in spark-tools-assembly.jar beat those in CLASSPATH or SPARK_CLASSPATH, which might be replaced by customized versions.
-
Reynold Xin authored
Show full stack trace and time taken in unit tests.
-
- Dec 23, 2013
-
-
Reynold Xin authored
-
Matei Zaharia authored
Refactored the streaming scheduler and added StreamingListener interface - Refactored the streaming scheduler for cleaner code. Specifically, the JobManager was renamed to JobScheduler, as it does the actual scheduling of Spark jobs to the SparkContext. The earlier Scheduler was renamed to JobGenerator, as it actually generates the jobs from the DStreams. The JobScheduler starts the JobGenerator. Also, moved all the scheduler related code from spark.streaming to spark.streaming.scheduler package. - Implemented the StreamingListener interface, similar to SparkListener. The streaming version of StatusReportListener prints the batch processing time statistics (for now). Added StreamingListernerSuite to test it. - Refactored streaming TestSuiteBase for deduping code in the other streaming testsuites.
-
Tathagata Das authored
-
Tathagata Das authored
-
Tathagata Das authored
-
Reynold Xin authored
Added SPARK-968 implementation for review Added SPARK-968 implementation for review
-
wangda.tan authored
-
- Dec 22, 2013
-
-
Kay Ousterhout authored
-
wangda.tan authored
-
Kay Ousterhout authored
-