aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
...
* [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-135-13/+16
* [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-0911-157/+165
* [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-3369][CORE][STREAMING] Java mapPartitions Iterator->Iterable is incons...Sean Owen2016-01-261-10/+10
* [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-4819] Remove Guava's "Optional" from public APISean Owen2016-01-082-3/+3
* [SPARK-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 editionSean Owen2016-01-083-49/+33
* [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-093-137/+137
* [SPARK-11932][STREAMING] Partition previous TrackStateRDD if partitioner not ...Tathagata Das2015-12-073-67/+205
* [SPARK-12106][STREAMING][FLAKY-TEST] BatchedWAL test transiently flaky when J...Burak Yavuz2015-12-071-4/+10
* [SPARK-12084][CORE] Fix codes that uses ByteBuffer.array incorrectlyShixiong Zhu2015-12-041-8/+7
* [SPARK-6990][BUILD] Add Java linting script; fix minor warningsDmitry Erastov2015-12-042-3/+3
* [FLAKY-TEST-FIX][STREAMING][TEST] Make sure StreamingContexts are shutdown af...Tathagata Das2015-12-031-61/+61
* [SPARK-12021][STREAMING][TESTS] Fix the potential dead-lock in StreamingListe...Shixiong Zhu2015-11-271-6/+19
* [SPARK-11979][STREAMING] Empty TrackStateRDD cannot be checkpointed and recov...Tathagata Das2015-11-242-10/+30
* [SPARK-11845][STREAMING][TEST] Added unit test to verify TrackStateRDD is cor...Tathagata Das2015-11-191-3/+57
* [SPARK-11791] Fix flaky test in BatchedWriteAheadLogSuiteBurak Yavuz2015-11-181-4/+8
* [SPARK-11814][STREAMING] Add better default checkpoint durationTathagata Das2015-11-181-1/+43
* [SPARK-11495] Fix potential socket / file handle leaks that were found via st...Josh Rosen2015-11-181-7/+13
* [SPARK-4557][STREAMING] Spark Streaming foreachRDD Java API method should acc...Bryan Cutler2015-11-181-1/+40
* [SPARK-11761] Prevent the call to StreamingContext#stop() in the listener bus...tedyu2015-11-171-0/+34
* [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batchShixiong Zhu2015-11-171-2/+25
* [SPARK-11731][STREAMING] Enable batching on Driver WriteAheadLog by defaultBurak Yavuz2015-11-164-6/+47
* [SPARK-11573] Correct 'reflective access of structural type member meth…Gábor Lipták2015-11-141-0/+1
* [SPARK-11681][STREAMING] Correctly update state timestamp even when state is ...Tathagata Das2015-11-121-5/+131
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-03 00:50:01 +0000