aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* [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
* [SPARK-11419][STREAMING] Parallel recovery for FileBasedWriteAheadLog + minor...Burak Yavuz2015-11-122-6/+172
* [SPARK-11663][STREAMING] Add Java API for trackStateByKeyShixiong Zhu2015-11-121-0/+210
* [SPARK-11290][STREAMING][TEST-MAVEN] Fix the test for maven buildShixiong Zhu2015-11-121-3/+9
* [SPARK-11639][STREAMING][FLAKY-TEST] Implement BlockingWriteAheadLog for test...Burak Yavuz2015-11-111-47/+77
* [SPARK-11290][STREAMING] Basic implementation of trackStateByKeyTathagata Das2015-11-103-0/+1001
* [SPARK-11361][STREAMING] Show scopes of RDD operations inside DStream.foreach...Tathagata Das2015-11-102-14/+65
* [SPARK-11333][STREAMING] Add executorId to ReceiverInfo and display it in UIShixiong Zhu2015-11-093-5/+12
* [SPARK-11462][STREAMING] Add JavaStreamingListenerzsxwing2015-11-092-0/+375
* [SPARK-11141][STREAMING] Batch ReceivedBlockTrackerLogEvents for WAL writesBurak Yavuz2015-11-092-167/+461
* [SPARK-11511][STREAMING] Fix NPE when an InputDStream is not usedShixiong Zhu2015-11-061-0/+16
* [SPARK-11212][CORE][STREAMING] Make preferred locations support ExecutorCache...zsxwing2015-10-272-42/+72
* [SPARK-11324][STREAMING] Flag for closing Write Ahead Logs after a writeBurak Yavuz2015-10-271-7/+25
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-03 03:56:20 +0000