aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
...
* [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
* [SPARK-5569][STREAMING] fix ObjectInputStreamWithLoader for supporting load a...maxwell2015-10-271-2/+33
* [SPARK-10984] Simplify *MemoryManager class structureJosh Rosen2015-10-251-1/+1
* [SPARK-11063] [STREAMING] Change preferredLocations of Receiver's RDD to host...zsxwing2015-10-191-0/+24
* [SPARK-10974] [STREAMING] Add progress bar for output operation column and us...zsxwing2015-10-163-20/+28
* [SPARK-11060] [STREAMING] Fix some potential NPE in DStream transformationjerryshao2015-10-161-0/+66
* [SPARK-10772] [STREAMING] [SCALA] NullPointerException when transform functio...Jacker Hu2015-10-101-0/+13
* [SPARK-10956] Common MemoryManager interface for storage and executionAndrew Or2015-10-081-5/+8
* [SPARK-10885] [STREAMING] Display the failed output op in Streaming UIzsxwing2015-10-061-2/+2
* [SPARK-10900] [STREAMING] Add output operation events to StreamingListenerzsxwing2015-10-051-0/+37
* [SPARK-10692] [STREAMING] Expose failureReasons in BatchInfo for streaming UI...zsxwing2015-09-231-0/+76
* [SPARK-10769] [STREAMING] [TESTS] Fix o.a.s.streaming.CheckpointSuite.maintai...zsxwing2015-09-231-1/+5
* [SPARK-10224] [STREAMING] Fix the issue that blockIntervalTimer won't call up...zsxwing2015-09-232-3/+87
* [SPARK-10652] [SPARK-10742] [STREAMING] Set meaningful job descriptions for a...Tathagata Das2015-09-221-1/+1
* [SPARK-10649] [STREAMING] Prevent inheriting job group and irrelevant job des...Tathagata Das2015-09-211-0/+32
* [SPARK-10547] [TEST] Streamline / improve style of Java API testsSean Owen2015-09-122-425/+413
* [SPARK-10071] [STREAMING] Output a warning when writing QueueInputDStream and...zsxwing2015-09-081-9/+19
* [SPARK-9767] Remove ConnectionManager.Reynold Xin2015-09-071-4/+6
* [SPARK-9869] [STREAMING] Wait for all event notifications before asserting re...robbins2015-09-031-0/+3
* [SPARK-10369] [STREAMING] Don't remove ReceiverTrackingInfo when deregisterRe...zsxwing2015-08-311-0/+51
* [SPARK-9613] [CORE] Ban use of JavaConversions and migrate all existing uses ...Sean Owen2015-08-252-19/+9
* [SPARK-10210] [STREAMING] Filter out non-existent blocks before creating Bloc...Tathagata Das2015-08-251-0/+156
* [SPARK-10137] [STREAMING] Avoid to restart receivers if scheduleReceivers ret...zsxwing2015-08-241-6/+7
* [SPARK-10098] [STREAMING] [TEST] Cleanup active context after test in Failure...Tathagata Das2015-08-181-10/+17
* [SPARK-9966] [STREAMING] Handle couple of corner cases in PIDRateEstimatorTathagata Das2015-08-141-28/+51
* Disable JobGeneratorSuite "Do not clear received block data too soon".Reynold Xin2015-08-091-1/+2
* [SPARK-9556] [SPARK-9619] [SPARK-9624] [STREAMING] Make BlockGenerator more r...Tathagata Das2015-08-065-138/+355
* [SPARK-9504] [STREAMING] [TESTS] Fix o.a.s.streaming.StreamingContextSuite.st...zsxwing2015-08-041-1/+2
* [SPARK-9534] [BUILD] Enable javac lint for scalac parity; fix a lot of build ...Sean Owen2015-08-042-32/+34
* [SPARK-9504] [STREAMING] [TESTS] Use eventually to fix the flaky testzsxwing2015-07-311-5/+5
generated by cgit v1.2.3 (git 2.39.1) at 2024-08-09 15:45:48 +0000