aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* [java8API] SPARK-964 Investigate the potential for using JDK 8 lambda express...Prashant Sharma2014-03-031-30/+32
* SPARK-1158: Fix flaky RateLimitedOutputStreamSuite.Reynold Xin2014-03-031-5/+8
* Ignore RateLimitedOutputStreamSuite for now.Reynold Xin2014-03-021-1/+1
* SPARK 1084.1 (resubmitted)Sean Owen2014-02-271-37/+87
* Made some classes private[stremaing] and deprecated a method in JavaStreaming...Tathagata Das2014-01-151-3/+3
* Changed SparkConf to not be serializable. And also fixed unit-test log paths ...Tathagata Das2014-01-141-8/+20
* Merge remote-tracking branch 'apache/master' into filestream-fixTathagata Das2014-01-132-23/+89
|\
| * Merge pull request #413 from rxin/scaladocPatrick Wendell2014-01-131-0/+40
| |\
| | * Adjusted visibility of various components.Reynold Xin2014-01-131-0/+40
| * | Added unpersisting and modified testsuite to better test out metadata cleaning.Tathagata Das2014-01-131-23/+49
| |/
* / Removed StreamingContext.registerInputStream and registerOutputStream - they ...Tathagata Das2014-01-136-14/+8
|/
* Merge pull request #400 from tdas/dstream-movePatrick Wendell2014-01-136-3/+21
|\
| * Merge remote-tracking branch 'apache/master' into dstream-moveTathagata Das2014-01-122-2/+2
| |\
| * | Fixed persistence logic of WindowedDStream, and fixed default persistence lev...Tathagata Das2014-01-121-0/+14
| * | Merge branch 'error-handling' into dstream-moveTathagata Das2014-01-122-10/+21
| |\ \
| * | | Moved DStream, DStreamCheckpointData and PairDStream from org.apache.spark.st...Tathagata Das2014-01-126-2/+6
* | | | Merge pull request #397 from pwendell/host-portReynold Xin2014-01-123-4/+0
|\ \ \ \ | |_|_|/ |/| | |
| * | | Removing mentions in testsPatrick Wendell2014-01-123-4/+0
* | | | Merge pull request #394 from tdas/error-handlingPatrick Wendell2014-01-124-8/+245
|\ \ \ \ | | |_|/ | |/| |
| * | | Changed StreamingContext.stopForWait to awaitTermination.Tathagata Das2014-01-122-9/+9
| * | | Fixed bugs to ensure better cleanup of JobScheduler, JobGenerator and Network...Tathagata Das2014-01-122-2/+13
| | |/ | |/|
| * | Merge remote-tracking branch 'apache/master' into error-handlingTathagata Das2014-01-111-10/+19
| |\|
| * | Converted JobScheduler to use actors for event handling. Changed protected[st...Tathagata Das2014-01-114-6/+232
* | | Rename DStream.foreach to DStream.foreachRDDPatrick Wendell2014-01-121-1/+1
| |/ |/|
* | Revert "Fix one unit test that was not setting spark.cleaner.ttl"Patrick Wendell2014-01-111-1/+1
* | Merge pull request #381 from mateiz/default-ttlMatei Zaharia2014-01-101-1/+1
|\ \
| * | Fix one unit test that was not setting spark.cleaner.ttlMatei Zaharia2014-01-101-1/+1
* | | Merge pull request #383 from tdas/driver-testPatrick Wendell2014-01-101-5/+5
|\ \ \ | | |/ | |/|
| * | Merge branch 'standalone-driver' into driver-testTathagata Das2014-01-097-203/+89
| |\|
| * | Modified checkpoing file clearing policy.Tathagata Das2014-01-081-5/+5
* | | Fix wonky imports from mergeAndrew Or2014-01-091-8/+1
* | | Merge github.com:apache/incubator-sparkAndrew Or2014-01-094-179/+68
|\ \ \ | | |/ | |/|
| * | Merge remote-tracking branch 'apache/master' into project-refactorTathagata Das2014-01-066-57/+55
| |\ \
| * | | Removed unnecessary comments.Tathagata Das2013-12-311-26/+0
| * | | Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-304-148/+62
* | | | Merge remote-tracking branch 'spark/master'Andrew Or2014-01-026-66/+70
|\ \ \ \ | | |/ / | |/| |
| * | | Merge pull request #297 from tdas/window-improvementPatrick Wendell2014-01-021-3/+1
| |\ \ \
| | * | | Updated groupByKeyAndWindow to be computed incrementally, and added mapSideCo...Tathagata Das2013-12-261-3/+1
| | |/ /
| * | | Merge remote-tracking branch 'apache/master' into conf2Matei Zaharia2013-12-312-23/+23
| |\ \ \ | | | |/ | | |/|
| | * | Removed slack time in file stream and added better handling of exceptions due...Tathagata Das2013-12-262-12/+0
| | * | Updated testsuites to work with the slack time of file stream.Tathagata Das2013-12-232-1/+13
| | * | Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-231-1/+1
| | |\|
| | * | Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-199-143/+212
| | |\ \
| | * | | Fixed multiple file stream and checkpointing bugs.Tathagata Das2013-12-111-15/+23
| * | | | Merge remote-tracking branch 'origin/master' into conf2Matei Zaharia2013-12-297-54/+125
| |\ \ \ \ | | | |_|/ | | |/| |
| * | | | Fix other failing testsMatei Zaharia2013-12-282-11/+6
| * | | | Fix CheckpointSuite test failuresMatei Zaharia2013-12-281-4/+3
| * | | | Fix test failures due to setting / clearing clock type in StreamingMatei Zaharia2013-12-284-10/+14
| * | | | Various fixes to configuration codeMatei Zaharia2013-12-282-5/+7
| * | | | spark-544, introducing SparkConf and related configuration overhaul.Prashant Sharma2013-12-253-17/+18