aboutsummaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Yarn Client refactorRaymond Liu2014-01-145-709/+450
* Merge pull request #410 from rxin/scaladoc1Reynold Xin2014-01-131-1/+1
|\
| * Updated JavaStreamingContext to make scaladoc compile.Reynold Xin2014-01-131-1/+1
|/
* Merge pull request #400 from tdas/dstream-movePatrick Wendell2014-01-1340-78/+121
|\
| * Fixed import formatting.Tathagata Das2014-01-126-6/+6
| * Merge remote-tracking branch 'apache/master' into dstream-moveTathagata Das2014-01-1212-24/+61
| |\
| * | Fixed persistence logic of WindowedDStream, and fixed default persistence lev...Tathagata Das2014-01-129-10/+41
| * | Merge remote-tracking branch 'apache/master' into dstream-moveTathagata Das2014-01-124-6/+18
| |\ \
| * \ \ Merge branch 'error-handling' into dstream-moveTathagata Das2014-01-1211-70/+110
| |\ \ \
| * | | | Moved DStream, DStreamCheckpointData and PairDStream from org.apache.spark.st...Tathagata Das2014-01-1237-70/+82
* | | | | Merge pull request #397 from pwendell/host-portReynold Xin2014-01-1216-52/+7
|\ \ \ \ \
| * | | | | Removing mentions in testsPatrick Wendell2014-01-1212-18/+2
| * | | | | Remove now un-needed hostPort optionPatrick Wendell2014-01-124-34/+5
* | | | | | Merge pull request #399 from pwendell/consolidate-offPatrick Wendell2014-01-122-2/+2
|\ \ \ \ \ \
| * | | | | | Disable shuffle file consolidation by defaultPatrick Wendell2014-01-122-2/+2
| |/ / / / /
* | | | | | Merge pull request #395 from hsaputra/remove_simpleredundantreturn_scalaPatrick Wendell2014-01-1263-194/+194
|\ \ \ \ \ \ | |_|_|_|_|/ |/| | | | |
| * | | | | Address code review concerns and comments.Henry Saputra2014-01-128-19/+18
| * | | | | Fix accidental comment modification.Henry Saputra2014-01-121-1/+1
| * | | | | Merge branch 'master' into remove_simpleredundantreturn_scalaHenry Saputra2014-01-12114-637/+3809
| |\| | | |
| * | | | | Remove simple redundant return statement for Scala methods/functions:Henry Saputra2014-01-1263-186/+187
* | | | | | Merge pull request #394 from tdas/error-handlingPatrick Wendell2014-01-1223-231/+591
|\ \ \ \ \ \
| * \ \ \ \ \ Merge remote-tracking branch 'apache/master' into error-handlingTathagata Das2014-01-124-6/+18
| |\ \ \ \ \ \ | | |_|_|_|/ / | |/| | | | / | | | |_|_|/ | | |/| | |
| * | | | | Changed StreamingContext.stopForWait to awaitTermination.Tathagata Das2014-01-124-15/+15
| * | | | | Fixed bugs to ensure better cleanup of JobScheduler, JobGenerator and Network...Tathagata Das2014-01-129-56/+96
| | |_|_|/ | |/| | |
| * | | | Fixed bugs.Tathagata Das2014-01-123-3/+3
| * | | | Merge remote-tracking branch 'apache/master' into error-handlingTathagata Das2014-01-1130-174/+1347
| |\ \ \ \ | | | |_|/ | | |/| |
| * | | | Added waitForStop and stop to JavaStreamingContext.Tathagata Das2014-01-112-3/+23
| * | | | Converted JobScheduler to use actors for event handling. Changed protected[st...Tathagata Das2014-01-1117-185/+485
* | | | | Merge pull request #398 from pwendell/streaming-apiPatrick Wendell2014-01-1210-28/+65
|\ \ \ \ \ | |_|_|/ / |/| | | |
| * | | | Adding deprecated versions of old codePatrick Wendell2014-01-122-8/+45
| * | | | Rename DStream.foreach to DStream.foreachRDDPatrick Wendell2014-01-1210-22/+22
| | |/ / | |/| |
* | | | Merge pull request #396 from pwendell/executor-envPatrick Wendell2014-01-121-1/+1
|\ \ \ \
| * | | | Setting load defaults to true in executorPatrick Wendell2014-01-121-1/+1
| |/ / /
* | | | Merge pull request #392 from rxin/listenerbusReynold Xin2014-01-123-5/+17
|\ \ \ \ | |/ / / |/| | |
| * | | Stop SparkListenerBus daemon thread when DAGScheduler is stopped.Reynold Xin2014-01-113-5/+17
* | | | Merge pull request #389 from rxin/clone-writablesReynold Xin2014-01-113-41/+71
|\ \ \ \
| * | | | Renamed cloneKeyValues to cloneRecords; updated docs.Reynold Xin2014-01-113-44/+45
| * | | | Minor update for clone writables and more documentation.Reynold Xin2014-01-113-12/+41
| |/ / /
* | | | Merge pull request #388 from pwendell/masterReynold Xin2014-01-111-1/+1
|\ \ \ \
| * | | | Fix UI bug introduced in #244.Patrick Wendell2014-01-111-1/+1
* | | | | Merge pull request #393 from pwendell/revert-381Patrick Wendell2014-01-112-2/+2
|\ \ \ \ \
| * | | | | Revert "Fix default TTL for metadata cleaner"Patrick Wendell2014-01-111-1/+1
| * | | | | Revert "Fix one unit test that was not setting spark.cleaner.ttl"Patrick Wendell2014-01-111-1/+1
|/ / / / /
* | | | | Merge pull request #387 from jerryshao/conf-fixReynold Xin2014-01-111-7/+8
|\ \ \ \ \ | |_|/ / / |/| | | |
| * | | | Fix configure didn't work small problem in ALSjerryshao2014-01-111-7/+8
* | | | | Merge pull request #359 from ScrapCodes/clone-writablesReynold Xin2014-01-114-49/+106
|\ \ \ \ \
| * | | | | Fixes corresponding to Reynolds feedback commentsPrashant Sharma2014-01-094-32/+43
| * | | | | we clone hadoop key and values by default and reuse if specified.Prashant Sharma2014-01-084-41/+87
* | | | | | Merge pull request #373 from jerryshao/kafka-upgradePatrick Wendell2014-01-112-11/+11
|\ \ \ \ \ \
| * | | | | | Upgrade Kafka dependecy to 0.8.0 release versionjerryshao2014-01-102-11/+11