aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test/scala/org
Commit message (Expand)AuthorAgeFilesLines
* [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-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
* [SPARK-13990] Automatically pick serializer when caching RDDsJosh Rosen2016-03-211-3/+5
* [SPARK-13921] Store serialized blocks as multiple chunks in MemoryStoreJosh Rosen2016-03-172-2/+2
* [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.internal.Lo...Wenchen Fan2016-03-178-5/+10
* [SPARK-13823][SPARK-13397][SPARK-13395][CORE] More warnings, StandardCharset ...Sean Owen2016-03-162-2/+3
* [MINOR][DOCS] Fix more typos in comments/strings.Dongjoon Hyun2016-03-146-8/+8
* [SPARK-13823][CORE][STREAMING][SQL] Always specify Charset in String <-> byte...Sean Owen2016-03-133-9/+9
* [SPARK-3854][BUILD] Scala style: require spaces before `{`.Dongjoon Hyun2016-03-101-3/+3
* [SPARK-13696] Remove BlockStore class & simplify interfaces of mem. & disk st...Josh Rosen2016-03-101-2/+8
* [SPARK-7420][STREAMING][TESTS] Enable test: o.a.s.streaming.JobGeneratorSuite...proflin2016-03-091-2/+1
* [SPARK-13693][STREAMING][TESTS] Stop StreamingContext before deleting checkpo...Shixiong Zhu2016-03-051-1/+1
* [SPARK-13398][STREAMING] Move away from thread pool task support to forkjoinHolden Karau2016-03-041-3/+6
* [SPARK-13583][CORE][STREAMING] Remove unused imports and add checkstyle ruleDongjoon Hyun2016-03-032-3/+1
* [SPARK-13423][WIP][CORE][SQL][STREAMING] Static analysis fixes for 2.xSean Owen2016-03-034-10/+10
* [SPARK-13399][STREAMING] Fix checkpointsuite type erasure warningsHolden Karau2016-02-221-6/+13
* [SPARK-13186][STREAMING] migrate away from SynchronizedMapHuaxin Gao2016-02-222-4/+11
* [SPARK-13248][STREAMING] Remove deprecated Streaming APIs.Luciano Resende2016-02-211-7/+0
* [STREAMING][TEST] Fix flaky streaming.FailureSuiteTathagata Das2016-02-112-2/+6
* [SPARK-13170][STREAMING] Investigate replacing SynchronizedQueue as it is dep...Sean Owen2016-02-091-13/+24
* [SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streamingHolden Karau2016-02-0910-155/+163
* [SPARK-13195][STREAMING] Fix NoSuchElementException when a state is not set b...Shixiong Zhu2016-02-041-0/+5
* [SPARK-12739][STREAMING] Details of batch in Streaming tab uses two Duration ...Mario Briggs2016-02-031-2/+3
* [SPARK-6847][CORE][STREAMING] Fix stack overflow issue when updateStateByKey ...Shixiong Zhu2016-02-011-0/+69
* [SPARK-7997][CORE] Remove Akka from Spark Core and StreamingShixiong Zhu2016-01-221-1/+0
* [SPARK-12847][CORE][STREAMING] Remove StreamingListenerBus and post all Strea...Shixiong Zhu2016-01-203-3/+23
* [SPARK-12692][BUILD][STREAMING] Scala style: Fix the style violation (Space b...Kousuke Saruta2016-01-118-11/+11
* [SPARK-3873][BUILD] Enable import ordering error checking.Marcelo Vanzin2016-01-101-3/+2
* [SPARK-12591][STREAMING] Register OpenHashMapBasedStateMap for KryoShixiong Zhu2016-01-071-13/+83
* [SPARK-7689] Remove TTL-based metadata cleaning in Spark 2.0Josh Rosen2016-01-061-9/+10
* [SPARK-3873][TESTS] Import ordering fixes.Marcelo Vanzin2016-01-0517-48/+46
* [SPARK-12481][CORE][STREAMING][SQL] Remove usage of Hadoop deprecated APIs an...Sean Owen2016-01-021-1/+2
* [SPARK-12311][CORE] Restore previous value of "os.arch" property in test suit...Kazuaki Ishizaki2015-12-249-21/+70
* [SPARK-11749][STREAMING] Duplicate creating the RDD in file stream when recov...jhu-chang2015-12-171-4/+52
* [STREAMING][MINOR] Fix typo in function name of StateImpljerryshao2015-12-151-1/+1
* [SPARK-12244][SPARK-12245][STREAMING] Rename trackStateByKey to mapWithState ...Tathagata Das2015-12-092-113/+113
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-22 05:30:14 +0000