aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* Fixed comments and long lines based on comments on PR 289.Tathagata Das2013-12-313-9/+17
* Minor changes in comments and strings to address comments in PR 289.Tathagata Das2013-12-271-8/+6
* Added warning if filestream adds files with no data in them (file RDDs have 0...Tathagata Das2013-12-261-0/+7
* Changed file stream to not catch any exceptions related to finding new files ...Tathagata Das2013-12-261-19/+11
* Removed slack time in file stream and added better handling of exceptions due...Tathagata Das2013-12-263-50/+21
* Fixed Python API for sc.setCheckpointDir. Also other fixes based on Reynold's...Tathagata Das2013-12-242-8/+9
* Minor formatting fixes.Tathagata Das2013-12-233-9/+13
* Updated testsuites to work with the slack time of file stream.Tathagata Das2013-12-233-2/+22
* Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-233-4/+26
|\
| * Minor change for PR 277.Tathagata Das2013-12-231-1/+1
| * Minor formatting fixes.Tathagata Das2013-12-231-5/+4
| * Added comments to BatchInfo and JobSet, based on Patrick's comment on PR 277.Tathagata Das2013-12-232-3/+26
* | Fixed bug in file stream that prevented some files from being readTathagata Das2013-12-231-9/+12
* | Updated CheckpointWriter and FileInputDStream to be robust against failed Fil...Tathagata Das2013-12-223-35/+78
* | Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-222-1/+6
|\|
| * Minor updated based on comments on PR 277.Tathagata Das2013-12-202-1/+6
* | Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-1957-620/+1009
|\|
| * Minor changes.Tathagata Das2013-12-189-32/+36
| * Merge branch 'apache-master' into scheduler-updateTathagata Das2013-12-1842-406/+458
| |\
| | * Use scala.binary.version in POMsMark Hamstra2013-12-151-7/+7
| | * Merge branch 'master' into akka-bug-fixPrashant Sharma2013-12-111-8/+1
| | |\
| | * | Style fixes and addressed review comments at #221Prashant Sharma2013-12-102-10/+10
| | * | Incorporated Patrick's feedback comment on #211 and made maven build/dep-reso...Prashant Sharma2013-12-071-1/+1
| | * | Merge branch 'master' of github.com:apache/incubator-spark into scala-2.10-tempPrashant Sharma2013-11-215-11/+12
| | |\ \
| | * \ \ Merge branch 'scala210-master' of github.com:colorant/incubator-spark into sc...Prashant Sharma2013-11-2132-295/+1500
| | |\ \ \
| | | * | | Various merge correctionsAaron Davidson2013-11-145-63/+2
| | | * | | Merge branch 'master' into scala-2.10Raymond Liu2013-11-142-7/+80
| | | |\ \ \
| | | * \ \ \ Merge branch 'master' into scala-2.10Raymond Liu2013-11-1331-228/+1421
| | | |\ \ \ \
| | * | | | | | Remove deprecated actorFor and use actorSelection everywhere.Prashant Sharma2013-11-121-1/+1
| | |/ / / / /
| | * | | | | Merge branch 'scala-2.10' of github.com:ScrapCodes/spark into scala-2.10Prashant Sharma2013-10-101-3/+4
| | |\ \ \ \ \
| | | * \ \ \ \ Merge branch 'master' into wip-merge-masterPrashant Sharma2013-10-081-2/+3
| | | |\ \ \ \ \
| | | * \ \ \ \ \ Merge branch 'master' into scala-2.10Prashant Sharma2013-10-011-1/+1
| | | |\ \ \ \ \ \
| | * | | | | | | | fixed some warningsMartin Weindel2013-10-0515-61/+76
| | |/ / / / / / /
| | * | | | | | | fixed maven build for scala 2.10Prashant Sharma2013-09-261-5/+9
| | * | | | | | | Akka 2.2 migrationPrashant Sharma2013-09-226-12/+15
| | * | | | | | | Few more fixes to tests broken during mergePrashant Sharma2013-09-101-3/+3
| | * | | | | | | Merged with masterPrashant Sharma2013-09-0677-801/+1731
| | |\ \ \ \ \ \ \
| | * | | | | | | | code formatting, The warning related to scope exit and enter is not worth fix...Prashant Sharma2013-07-161-14/+14
| | * | | | | | | | Fixed warning erasure -> runtimeClassPrashant Sharma2013-07-161-1/+1
| | * | | | | | | | Fixed warning ThrowablesPrashant Sharma2013-07-161-1/+1
| | * | | | | | | | Fixed warning ClassManifest -> ClassTagPrashant Sharma2013-07-161-1/+1
| | * | | | | | | | Merge branch 'master' into master-mergePrashant Sharma2013-07-126-18/+29
| | |\ \ \ \ \ \ \ \
| | * \ \ \ \ \ \ \ \ Merge branch 'master' into master-mergePrashant Sharma2013-07-0316-148/+292
| | |\ \ \ \ \ \ \ \ \
| | * | | | | | | | | | Updated to latest stable scala 2.10.1 and akka 2.1.2Prashant Sharma2013-05-011-12/+2
| | * | | | | | | | | | Fixied other warningsPrashant Sharma2013-04-291-3/+1
| | * | | | | | | | | | Fixed warning: erasure -> runtimeClassPrashant Sharma2013-04-291-4/+4
| | * | | | | | | | | | Fixed Warning: ClassManifest -> ClassTagPrashant Sharma2013-04-2939-239/+285
| | * | | | | | | | | | Fixed pom.xml with updated dependencies.Prashant Sharma2013-04-291-1/+11
| | * | | | | | | | | | Fixed breaking tests in streaming checkpoint suite. Changed RichInt to Int as...Prashant Sharma2013-04-251-16/+19
| | * | | | | | | | | | scala 2.10 and master mergePrashant Sharma2013-04-244-15/+16