aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* Preparing Spark release v1.2.0-rc1Patrick Wendell2014-11-281-1/+1
* Revert "Preparing Spark release v1.2.0-rc1"Patrick Wendell2014-11-261-1/+1
* Revert "Preparing development version 1.2.1-SNAPSHOT"Patrick Wendell2014-11-261-1/+1
* Preparing development version 1.2.1-SNAPSHOTPatrick Wendell2014-11-261-1/+1
* Preparing Spark release v1.2.0-rc1Patrick Wendell2014-11-261-1/+1
* Revert "Preparing Spark release v1.2.0-rc1"Patrick Wendell2014-11-261-1/+1
* Revert "Preparing development version 1.2.1-SNAPSHOT"Patrick Wendell2014-11-261-1/+1
* Preparing development version 1.2.1-SNAPSHOTPatrick Wendell2014-11-261-1/+1
* Preparing Spark release v1.2.0-rc1Patrick Wendell2014-11-261-1/+1
* Revert "Preparing Spark release v1.2.0-rc1"Patrick Wendell2014-11-261-1/+1
* Revert "Preparing development version 1.2.1-SNAPSHOT"Patrick Wendell2014-11-261-1/+1
* Preparing development version 1.2.1-SNAPSHOTUbuntu2014-11-261-1/+1
* Preparing Spark release v1.2.0-rc1Ubuntu2014-11-261-1/+1
* Revert "Preparing Spark release v1.2.0-snapshot1"Patrick Wendell2014-11-261-1/+1
* Revert "Preparing development version 1.2.1-SNAPSHOT"Patrick Wendell2014-11-261-1/+1
* [HOTFIX] Fixing broken build due to missing imports.Tathagata Das2014-11-251-0/+1
* [SPARK-4196][SPARK-4602][Streaming] Fix serialization issue in PairDStreamFun...Tathagata Das2014-11-252-16/+70
* [SPARK-4601][Streaming] Set correct call site for streaming jobs so that it i...Tathagata Das2014-11-252-1/+6
* [SPARK-4381][Streaming]Add warning log when user set spark.master to local in...jerryshao2014-11-251-0/+5
* [SPARK-4535][Streaming] Fix the error in commentsq002515982014-11-254-7/+7
* [SPARK-4518][SPARK-4519][Streaming] Refactored file stream to prevent files f...Tathagata Das2014-11-244-156/+245
* [SPARK-4481][Streaming][Doc] Fix the wrong description of updateFunc (backpor...zsxwing2014-11-201-4/+3
* [SPARK-4294][Streaming] UnionDStream stream should express the requirements i...Yadong Qi2014-11-191-11/+4
* [SPARK-4482][Streaming] Disable ReceivedBlockTracker's write ahead log by def...Tathagata Das2014-11-192-26/+61
* [SPARK-4180] [Core] Prevent creation of multiple active SparkContextsJosh Rosen2014-11-172-102/+136
* Preparing development version 1.2.1-SNAPSHOTUbuntu2014-11-171-1/+1
* Preparing Spark release v1.2.0-snapshot1Ubuntu2014-11-171-1/+1
* Revert "Preparing Spark release v1.2.0-snapshot0"Patrick Wendell2014-11-161-1/+1
* Revert "Preparing development version 1.2.1-SNAPSHOT"Patrick Wendell2014-11-161-2/+2
* Preparing development version 1.2.1-SNAPSHOTUbuntu2014-11-171-2/+2
* Preparing Spark release v1.2.0-snapshot0Ubuntu2014-11-171-1/+1
* [SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...jerryshao2014-11-143-11/+60
* [SPARK-4370] [Core] Limit number of Netty cores based on executor sizeAaron Davidson2014-11-121-1/+1
* [Streaming][Minor]Replace some 'if-else' in Clockhuangzhaowei2014-11-111-13/+2
* [SPARK-3954][Streaming] Optimization to FileInputDStreamsurq2014-11-101-3/+4
* [SPARK-4301] StreamingContext should not allow start() to be called after cal...Josh Rosen2014-11-082-23/+40
* [SPARK-4242] [Core] Add SASL to external shuffle serviceAaron Davidson2014-11-051-1/+1
* [SPARK-2938] Support SASL authentication in NettyBlockTransferServiceAaron Davidson2014-11-051-0/+1
* [SPARK-4029][Streaming] Update streaming driver to reliably save and recover ...Tathagata Das2014-11-058-89/+597
* [SPARK-4183] Close transport-related resources between SparkContextsAaron Davidson2014-11-021-0/+4
* [SPARK-4027][Streaming] WriteAheadLogBackedBlockRDD to read received either f...Tathagata Das2014-10-303-3/+281
* [SPARK-4028][Streaming] ReceivedBlockHandler interface to abstract the functi...Tathagata Das2014-10-3011-70/+603
* [SPARK-4053][Streaming] Made the ReceiverSuite test more reliable, by fixing ...Tathagata Das2014-10-291-14/+30
* [SPARK-4080] Only throw IOException from [write|read][Object|External]Josh Rosen2014-10-246-13/+16
* [SPARK-4026][Streaming] Write ahead log managementHari Shreedharan2014-10-247-0/+892
* replace awaitTransformation with awaitTermination in scaladoc/javadocHolden Karau2014-10-212-2/+2
* [SPARK-2377] Python API for Streaminggiwa2014-10-122-1/+317
* [SPARK-2805] Upgrade Akka to 2.3.4Anand Avati2014-10-101-71/+0
* SPARK-3811 [CORE] More robust / standard Utils.deleteRecursively, Utils.creat...Sean Owen2014-10-094-9/+5
* Revert "[SPARK-2805] Upgrade to akka 2.3.4"Patrick Wendell2014-10-091-0/+71
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-09 16:59:19 +0000