aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [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-182-1/+56
* [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-182-2/+63
* [SPARK-11761] Prevent the call to StreamingContext#stop() in the listener bus...tedyu2015-11-172-1/+39
* [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batchShixiong Zhu2015-11-172-4/+41
* [SPARK-11742][STREAMING] Add the failure info to the batch listsShixiong Zhu2015-11-163-50/+120
* [SPARK-6328][PYTHON] Python API for StreamingListenerDaniel Jalova2015-11-161-0/+76
* [SPARK-11731][STREAMING] Enable batching on Driver WriteAheadLog by defaultBurak Yavuz2015-11-165-7/+48
* [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-122-49/+192
* [SPARK-11419][STREAMING] Parallel recovery for FileBasedWriteAheadLog + minor...Burak Yavuz2015-11-127-37/+268
* [SPARK-11663][STREAMING] Add Java API for trackStateByKeyShixiong Zhu2015-11-128-27/+393
* [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-112-47/+80
* [SPARK-11290][STREAMING] Basic implementation of trackStateByKeyTathagata Das2015-11-109-4/+2115
* [SPARK-11361][STREAMING] Show scopes of RDD operations inside DStream.foreach...Tathagata Das2015-11-105-28/+141
* Add mockito as an explicit test dependency to spark-streamingBurak Yavuz2015-11-091-0/+5
* [SPARK-11333][STREAMING] Add executorId to ReceiverInfo and display it in UIShixiong Zhu2015-11-098-7/+22
* [SPARK-11462][STREAMING] Add JavaStreamingListenerzsxwing2015-11-094-0/+665
* [SPARK-11141][STREAMING] Batch ReceivedBlockTrackerLogEvents for WAL writesBurak Yavuz2015-11-096-192/+767
* [SPARK-11511][STREAMING] Fix NPE when an InputDStream is not usedShixiong Zhu2015-11-062-1/+18
* [SPARK-11457][STREAMING][YARN] Fix incorrect AM proxy filter conf recovery fr...jerryshao2015-11-051-1/+12
* [SPARK-11440][CORE][STREAMING][BUILD] Declare rest of @Experimental items non...Sean Owen2015-11-052-6/+0
* [SPARK-11212][CORE][STREAMING] Make preferred locations support ExecutorCache...zsxwing2015-10-276-130/+201
* [SPARK-11324][STREAMING] Flag for closing Write Ahead Logs after a writeBurak Yavuz2015-10-273-9/+44
* [SPARK-5569][STREAMING] fix ObjectInputStreamWithLoader for supporting load a...maxwell2015-10-272-3/+36
* [SPARK-10984] Simplify *MemoryManager class structureJosh Rosen2015-10-251-1/+1
* [SPARK-11063] [STREAMING] Change preferredLocations of Receiver's RDD to host...zsxwing2015-10-193-2/+29
* [SPARK-11104] [STREAMING] Fix a deadlock in StreamingContex.stopzsxwing2015-10-161-24/+31
* [SPARK-10974] [STREAMING] Add progress bar for output operation column and us...zsxwing2015-10-1614-201/+258
* [SPARK-11060] [STREAMING] Fix some potential NPE in DStream transformationjerryshao2015-10-165-9/+83
* [SPARK-10619] Can't sort columns on Executor PageTom Graves2015-10-141-1/+1
* [SPARK-10772] [STREAMING] [SCALA] NullPointerException when transform functio...Jacker Hu2015-10-102-2/+23
* [SPARK-10956] Common MemoryManager interface for storage and executionAndrew Or2015-10-081-5/+8
* [SPARK-10955] [STREAMING] Add a warning if dynamic allocation for Streaming a...Hari Shreedharan2015-10-081-1/+8
* [SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests.py.Marcelo Vanzin2015-10-071-10/+4
* [SPARK-10885] [STREAMING] Display the failed output op in Streaming UIzsxwing2015-10-066-27/+143
* [SPARK-10900] [STREAMING] Add output operation events to StreamingListenerzsxwing2015-10-057-9/+125
* FIX: rememberDuration reassignment error messageGuillaume Poulin2015-10-031-11/+5
* [SPARK-6028] [CORE] Remerge #6457: new RPC implemetation and also pick #8905zsxwing2015-10-031-1/+1
* Revert "[SPARK-6028][Core]A new RPC implemetation based on the network module"Xiangrui Meng2015-09-241-1/+1
* [SPARK-10692] [STREAMING] Expose failureReasons in BatchInfo for streaming UI...zsxwing2015-09-234-16/+115
* [SPARK-6028][Core]A new RPC implemetation based on the network modulezsxwing2015-09-231-1/+1
* [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-233-9/+100
* [SPARK-10652] [SPARK-10742] [STREAMING] Set meaningful job descriptions for a...Tathagata Das2015-09-225-17/+42
* [SPARK-10649] [STREAMING] Prevent inheriting job group and irrelevant job des...Tathagata Das2015-09-212-3/+44
* Revert "[SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests....Marcelo Vanzin2015-09-151-0/+10
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-03 14:56:54 +0000