aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-5943][Streaming] Update the test to use new API to reduce the warningSaisai Shao2015-02-232-6/+6
* SPARK-4682 [CORE] Consolidate various 'Clock' classesSean Owen2015-02-198-65/+57
* SPARK-5795 [STREAMING] api.java.JavaPairDStream.saveAsNewAPIHadoopFiles may n...Sean Owen2015-02-161-0/+18
* [SPARK-5379][Streaming] Add awaitTerminationOrTimeoutzsxwing2015-02-041-0/+24
* [SPARK-4969][STREAMING][PYTHON] Add binaryRecords to streamingfreeman2015-02-031-0/+51
* [STREAMING] SPARK-4986 Wait for receivers to deregister and receiver job to t...Jesper Lundgren2015-02-031-0/+58
* Make sure only owner can read / write to directories created for the job.Marcelo Vanzin2015-02-021-2/+2
* 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-221-2/+18
* [SPARK-5233][Streaming] Fix error replaying of WAL introduced bugjerryshao2015-01-221-10/+10
* [SPARK-5147][Streaming] Delete the received data WAL log periodicallyTathagata Das2015-01-211-31/+126
* [SPARK-5297][Streaming] Fix Java file stream type erasure problemjerryshao2015-01-201-5/+65
* [SPARK-4803] [streaming] Remove duplicate RegisterReceiver messageIlayaperumal Gopinathan2015-01-201-2/+2
* SPARK-4159 [CORE] Maven build doesn't run JUnit test suitesSean Owen2015-01-061-3/+2
* [SPARK-1600] Refactor FileInputStream tests to remove Thread.sleep() calls an...Josh Rosen2015-01-064-129/+236
* [SPARK-4835] Disable validateOutputSpecs for Spark Streaming jobsJosh Rosen2015-01-041-0/+39
* [SPARK-4790][STREAMING] Fix ReceivedBlockTrackerSuite waits for old file...Hari Shreedharan2014-12-313-4/+18
* [SPARK-1010] Clean up uses of System.setProperty in unit testsJosh Rosen2014-12-301-2/+6
* [SPARK-4608][Streaming] Reorganize StreamingContext implicit to improve API c...zsxwing2014-12-255-4/+35
* SPARK-4297 [BUILD] Build warning fixes omnibusSean Owen2014-12-241-8/+8
* [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-251-2/+54
* [SPARK-4601][Streaming] Set correct call site for streaming jobs so that it i...Tathagata Das2014-11-251-1/+5
* [SPARK-4518][SPARK-4519][Streaming] Refactored file stream to prevent files f...Tathagata Das2014-11-242-50/+58
* [SPARK-4482][Streaming] Disable ReceivedBlockTracker's write ahead log by def...Tathagata Das2014-11-191-14/+36
* [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-141-2/+6
* [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-122-4/+123
* [SPARK-4301] StreamingContext should not allow start() to be called after cal...Josh Rosen2014-11-081-6/+19
* [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-053-11/+254
* [SPARK-2938] Support SASL authentication in NettyBlockTransferServiceAaron Davidson2014-11-041-0/+1
* [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-301-0/+151
* [SPARK-4028][Streaming] ReceivedBlockHandler interface to abstract the functi...Tathagata Das2014-10-302-13/+279
* [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-241-2/+2
* [SPARK-4026][Streaming] Write ahead log managementHari Shreedharan2014-10-241-0/+357
* [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-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-1/+401
* [SPARK-546] Add full outer join to RDD and DStream.Aaron Staple2014-09-241-0/+15
* [SPARK-1853] Show Streaming application code context (file, line number) in S...Mubarak Seyed2014-09-231-2/+43
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-11 20:59:37 +0000