aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* 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
* [SPARK-2805] Upgrade to akka 2.3.4Anand Avati2014-10-081-71/+0
* [SPARK-3762] clear reference of SparkEnv after stopDavies Liu2014-10-073-3/+0
* [SPARK-3377] [SPARK-3610] Metrics can be accidentally aggregated / History se...Kousuke Saruta2014-10-031-4/+10
* [SPARK-3748] Log thread name in unit test logsReynold Xin2014-10-011-1/+1
* Minor cleanup to tighten visibility and remove compilation warning.Reynold Xin2014-09-271-23/+24
* SPARK-2932 [STREAMING] Move MasterFailureTest out of "main" source directorySean Owen2014-09-252-36/+8
* [SPARK-546] Add full outer join to RDD and DStream.Aaron Staple2014-09-243-4/+101
* [SPARK-1853] Show Streaming application code context (file, line number) in S...Mubarak Seyed2014-09-233-38/+107
* SPARK-2745 [STREAMING] Add Java friendly methods to Duration classSean Owen2014-09-236-2/+425
* SPARK-3470 [CORE] [STREAMING] Add Closeable / close() to Java context objectsSean Owen2014-09-121-2/+5
* SPARK-2482: Resolve sbt warnings during buildwitgo2014-09-114-5/+0
* [Spark-3490] Disable SparkUI for testsAndrew Or2014-09-114-13/+41
* [Docs] actorStream storageLevel default is MEMORY_AND_DISK_SER_2Mario Pastorelli2014-09-091-1/+1
* [SPARK-3397] Bump pom.xml version number of master branch to 1.2.0-SNAPSHOTGuoQiang Li2014-09-061-1/+1
* [SPARK-3285] [examples] Using values.sum is easier to understand than using v...Yadong Qi2014-08-282-3/+3
* [SPARK-2886] Use more specific actor system name than "spark"Andrew Or2014-08-251-5/+5
* [HOTFIX][Streaming][MLlib] use temp folder for checkpointXiangrui Meng2014-08-191-6/+11
* [SPARK-3128][MLLIB] Use streaming test suite for StreamingLRfreeman2014-08-191-1/+3
* [SPARK-2169] Don't copy appName / basePath everywhere.Marcelo Vanzin2014-08-182-6/+3
* [SPARK-2924] remove default args to overloaded methodsAnand Avati2014-08-151-1/+7
* SPARK-2955 [BUILD] Test code fails to compile with "mvn compile" without "ins...Sean Owen2014-08-141-4/+4
* Minor cleanup of metrics.SourceReynold Xin2014-08-141-3/+3
* [SPARK-2454] Do not ship spark home to WorkersAndrew Or2014-08-021-1/+0
* [SPARK-2379] Fix the bug that streaming's receiver may fall into a dead loopjoyyoj2014-08-011-1/+1
* SPARK-2749 [BUILD]. Spark SQL Java tests aren't compiling in Jenkins' Maven b...Sean Owen2014-07-301-0/+5
* [SPARK-2410][SQL] Merging Hive Thrift/JDBC server (with Maven profile fix)Cheng Lian2014-07-281-1/+1
* Revert "[SPARK-2410][SQL] Merging Hive Thrift/JDBC server"Patrick Wendell2014-07-271-1/+1
* [SPARK-1777] Prevent OOMs from single partitionsAndrew Or2014-07-271-3/+2
* [SPARK-2410][SQL] Merging Hive Thrift/JDBC serverCheng Lian2014-07-271-1/+1
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-10 03:55:49 +0000