aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-5466] Add explicit guava dependencies where needed.Marcelo Vanzin2015-01-291-0/+4
* [SPARK-4809] Rework Guava library shading.Marcelo Vanzin2015-01-281-0/+8
* SPARK-4430 [STREAMING] [TEST] Apache RAT Checks fail spuriously on test filesSean Owen2015-01-251-7/+2
* [SPARK-5315][Streaming] Fix reduceByWindow Java API not work bugjerryshao2015-01-222-2/+38
* [SPARK-5233][Streaming] Fix error replaying of WAL introduced bugjerryshao2015-01-223-19/+31
* [SPARK-5147][Streaming] Delete the received data WAL log periodicallyTathagata Das2015-01-219-50/+172
* [SPARK-5297][Streaming] Fix Java file stream type erasure problemjerryshao2015-01-202-15/+108
* [SPARK-5275] [Streaming] include python source codeDavies Liu2015-01-201-0/+8
* [SPARK-4803] [streaming] Remove duplicate RegisterReceiver messageIlayaperumal Gopinathan2015-01-202-9/+2
* [SPARK-4999][Streaming] Change storeInBlockManager to false by defaultjerryshao2015-01-121-1/+1
* [SPARK-5181] do not print writing WAL log when WAL is disabledCodingCat2015-01-101-2/+4
* [SPARK-4048] Enhance and extend hadoop-provided profile.Marcelo Vanzin2015-01-081-4/+4
* SPARK-4159 [CORE] Maven build doesn't run JUnit test suitesSean Owen2015-01-062-13/+2
* [SPARK-1600] Refactor FileInputStream tests to remove Thread.sleep() calls an...Josh Rosen2015-01-066-136/+251
* [SPARK-4835] Disable validateOutputSpecs for Spark Streaming jobsJosh Rosen2015-01-044-4/+55
* [SPARK-3325][Streaming] Add a parameter to the method print in class DStreamYadong Qi2015-01-022-4/+20
* [SPARK-5035] [Streaming] ReceiverMessage trait should extend SerializableJosh Rosen2014-12-311-1/+1
* [SPARK-5028][Streaming]Add total received and processed records metrics to St...jerryshao2014-12-311-0/+6
* [SPARK-4790][STREAMING] Fix ReceivedBlockTrackerSuite waits for old file...Hari Shreedharan2014-12-317-16/+42
* [SPARK-1010] Clean up uses of System.setProperty in unit testsJosh Rosen2014-12-301-2/+6
* [SPARK-4813][Streaming] Fix the issue that ContextWaiter didn't handle 'spuri...zsxwing2014-12-301-15/+48
* SPARK-4971: Fix typo in BlockGenerator commentCodingCat2014-12-261-1/+1
* [SPARK-4608][Streaming] Reorganize StreamingContext implicit to improve API c...zsxwing2014-12-2511-21/+58
* [SPARK-4537][Streaming] Expand StreamingSource to add more metricsjerryshao2014-12-252-15/+57
* [SPARK-4873][Streaming] Use `Future.zip` instead of `Future.flatMap`(for-loop...zsxwing2014-12-241-4/+1
* SPARK-4297 [BUILD] Build warning fixes omnibusSean Owen2014-12-241-8/+8
* [SPARK-4671][Streaming]Do not replicate streaming block when WAL is enabledjerryshao2014-12-231-1/+19
* [SPARK-4802] [streaming] Remove receiverInfo once receiver is de-registeredIlayaperumal Gopinathan2014-12-231-2/+2
* [SPARK-4668] Fix some documentation typos.Ryan Williams2014-12-151-1/+1
* [SPARK-4826] Fix generation of temp file names in WAL testsJosh Rosen2014-12-152-17/+20
* HOTFIX: Disabling failing block manager testPatrick Wendell2014-12-151-5/+5
* [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-4294][Streaming] UnionDStream stream should express the requirements i...Yadong Qi2014-11-191-11/+4
* [SPARK-4481][Streaming][Doc] Fix the wrong description of updateFunczsxwing2014-11-191-9/+7
* [SPARK-4482][Streaming] Disable ReceivedBlockTracker's write ahead log by def...Tathagata Das2014-11-192-26/+61
* Bumping version to 1.3.0-SNAPSHOT.Marcelo Vanzin2014-11-181-1/+1
* [SPARK-4180] [Core] Prevent creation of multiple active SparkContextsJosh Rosen2014-11-172-102/+136
* [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
* [SPARK-3660][STREAMING] Initial RDD for updateStateByKey transformationSoumitra Kumar2014-11-125-36/+229
* [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-4029][Streaming] Update streaming driver to reliably save and recover ...Tathagata Das2014-11-058-89/+597
* [SPARK-2938] Support SASL authentication in NettyBlockTransferServiceAaron Davidson2014-11-041-0/+1
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-04 12:49:02 +0000