aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-20156][CORE][SQL][STREAMING][MLLIB] Java String toLowerCase "Turkish l...Sean Owen2017-04-103-5/+7
* [SPARK-19556][CORE] Do not encrypt block manager data in memory.Marcelo Vanzin2017-03-292-5/+3
* [SPARK-19822][TEST] CheckpointSuite.testCheckpointedOperation: should not fil...uncleGen2017-03-051-3/+1
* [MINOR][BUILD] Fix lint-java breaks in Javahyukjinkwon2017-02-273-32/+44
* [SPARK-19646][CORE][STREAMING] binaryRecords replicates records in scala APISean Owen2017-02-201-10/+11
* [SPARK-19534][TESTS] Convert Java tests to use lambdas, Java 8 featuresSean Owen2017-02-195-500/+162
* [SPARK-19550][BUILD][CORE][WIP] Remove Java 7 supportSean Owen2017-02-162-1/+896
* [SPARK-19520][STREAMING] Do not encrypt data written to the WAL.Marcelo Vanzin2017-02-132-14/+56
* [SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...hyukjinkwon2017-01-101-3/+11
* [MINOR][DOCS] Remove consecutive duplicated words/typo in Spark RepoNiranjan Padmanabhan2017-01-043-4/+4
* [SPARK-18537][WEB UI] Add a REST api to serve spark streaming informationsaturday_s2016-12-223-0/+18
* [FLAKY-TEST] InputStreamsSuite.socket input streamBurak Yavuz2016-12-211-32/+23
* [SPARK-18954][TESTS] Fix flaky test: o.a.s.streaming.BasicOperationsSuite rdd...Shixiong Zhu2016-12-212-44/+73
* [SPARK-18031][TESTS] Fix flaky test ExecutorAllocationManagerSuite.basic func...Shixiong Zhu2016-12-211-4/+32
* [SPARK-18617][SPARK-18560][TESTS] Fix flaky test: StreamingContextSuite. Rece...Shixiong Zhu2016-12-011-1/+3
* [SPARK-18617][SPARK-18560][TEST] Fix flaky test: StreamingContextSuite. Recei...Shixiong Zhu2016-11-301-26/+8
* [SPARK-18617][CORE][STREAMING] Close "kryo auto pick" feature for Spark Strea...uncleGen2016-11-291-0/+47
* [SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...hyukjinkwon2016-11-191-1/+1
* [SPARK-13027][STREAMING] Added batch time as a parameter to updateStateByKeyAaditya Ramesh2016-11-152-0/+78
* [SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and e...wm624@hotmail.com2016-11-102-0/+2
* [SPARK-14914][CORE] Fix Resource not closed after using, mostly for unit testsHyukjin Kwon2016-11-075-7/+17
* [SPARK-18204][WEBUI] Remove SparkUI.appUIAddressJacek Laskowski2016-11-021-6/+6
* [SPARK-17365][CORE] Remove/Kill multiple executors together to reduce RPC cal...Dhruve Ashar2016-09-221-2/+3
* [SPARK-4563][CORE] Allow driver to advertise a different network address.Marcelo Vanzin2016-09-212-2/+4
* [SPARK-17110] Fix StreamCorruptionException in BlockManager.getRemoteValues()Josh Rosen2016-09-061-1/+2
* [SPARK-17038][STREAMING] fix metrics retrieval source of 'lastReceivedBatch'Xin Ren2016-08-171-0/+3
* [SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add mu...Holden Karau2016-08-081-1/+0
* [SPARK-16694][CORE] Use for/foreach rather than map for Unit expressions whos...Sean Owen2016-07-301-1/+1
* [SPARK-15703][SCHEDULER][CORE][WEBUI] Make ListenerBus event queue size confi...Dhruve Ashar2016-07-261-1/+4
* [SPARK-16722][TESTS] Fix a StreamingContext leak in StreamingContextSuite whe...Shixiong Zhu2016-07-251-3/+6
* [SPARK-16120][STREAMING] getCurrentLogFiles in ReceiverSuite WAL generating a...Ahmed Mahran2016-06-221-1/+1
* [SPARK-15086][CORE][STREAMING] Deprecate old Java accumulator APISean Owen2016-06-121-3/+3
* [MINOR] Fix Typos 'an -> a'Zheng RuiFeng2016-06-062-2/+2
* [SPARK-14976][STREAMING] make StreamingContext.textFileStream support wildcardmwws2016-05-111-0/+62
* [MINOR][TEST][STREAMING] make "testDir" able to be claened after test.mwws2016-05-091-4/+4
* [SPARK-1239] Improve fetching of map output statusesThomas Graves2016-05-061-1/+3
* Revert "[SPARK-14719] WriteAheadLogBasedBlockHandler should ignore BlockManag...Josh Rosen2016-04-191-26/+23
* [SPARK-14676] Wrap and re-throw Await.result exceptions in order to capture f...Josh Rosen2016-04-191-2/+3
* [SPARK-14719] WriteAheadLogBasedBlockHandler should ignore BlockManager put e...Josh Rosen2016-04-181-23/+26
* [SPARK-14667] Remove HashShuffleManagerReynold Xin2016-04-181-2/+2
* [SPARK-14544] [SQL] improve performance of SQL UI tabDavies Liu2016-04-121-2/+2
* [SPARK-14508][BUILD] Add a new ScalaStyle Rule `OmitBracesInCase`Dongjoon Hyun2016-04-123-8/+4
* [SPARK-14475] Propagate user-defined context from driver to executorsEric Liang2016-04-111-1/+9
* [SPARK-14455][STREAMING] Fix NPE in allocatedExecutors when calling in receiv...jerryshao2016-04-091-1/+22
* [SPARK-14437][CORE] Use the address that NettyBlockTransferService listens to...Shixiong Zhu2016-04-081-1/+1
* [SPARK-14134][CORE] Change the package name used for shading classes.Marcelo Vanzin2016-04-061-1/+1
* [SPARK-12133][STREAMING] Streaming dynamic allocationTathagata Das2016-04-061-0/+395
* [SPARK-13211][STREAMING] StreamingContext throws NoSuchElementException when ...Sean Owen2016-04-051-0/+5
* [SPARK-13992] Add support for off-heap cachingJosh Rosen2016-04-011-1/+2
* [SPARK-14075] Refactor MemoryStore to be testable independent of BlockManagerJosh Rosen2016-03-232-8/+12
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-18 16:03:49 +0000