aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
...
* [STREAMING][MINOR] Fix typo in function name of StateImpljerryshao2015-12-152-2/+2
* [SPARK-12273][STREAMING] Make Spark Streaming web UI list Receivers in orderproflin2015-12-111-2/+3
* [SPARK-11713] [PYSPARK] [STREAMING] Initial RDD updateStateByKey for PySparkBryan Cutler2015-12-101-2/+12
* [SPARK-12136][STREAMING] rddToFileName does not properly handle prefix and su...bomeng2015-12-101-6/+7
* [SPARK-12244][SPARK-12245][STREAMING] Rename trackStateByKey to mapWithState ...Tathagata Das2015-12-097-221/+230
* [SPARK-11932][STREAMING] Partition previous TrackStateRDD if partitioner not ...Tathagata Das2015-12-073-17/+53
* [SPARK-12106][STREAMING][FLAKY-TEST] BatchedWAL test transiently flaky when J...Burak Yavuz2015-12-071-2/+4
* [SPARK-12084][CORE] Fix codes that uses ByteBuffer.array incorrectlyShixiong Zhu2015-12-043-22/+12
* [SPARK-6990][BUILD] Add Java linting script; fix minor warningsDmitry Erastov2015-12-041-5/+5
* [SPARK-12122][STREAMING] Prevent batches from being submitted twice after rec...Tathagata Das2015-12-041-1/+2
* [SPARK-12001] Allow partially-stopped StreamingContext to be completely stoppedJosh Rosen2015-12-021-22/+27
* [SPARK-12087][STREAMING] Create new JobConf for every batch in saveAsHadoopFilesTathagata Das2015-12-011-1/+2
* [SPARK-12046][DOC] Fixes various ScalaDoc/JavaDoc issuesCheng Lian2015-12-016-52/+60
* [SPARK-11935][PYSPARK] Send the Python exceptions in TransformFunction and Tr...Shixiong Zhu2015-11-251-9/+43
* [SPARK-11979][STREAMING] Empty TrackStateRDD cannot be checkpointed and recov...Tathagata Das2015-11-241-7/+12
* [STREAMING][FLAKY-TEST] Catch execution context race condition in `FileBasedW...Burak Yavuz2015-11-241-5/+11
* [SPARK-11814][STREAMING] Add better default checkpoint durationTathagata Das2015-11-181-0/+13
* [SPARK-4557][STREAMING] Spark Streaming foreachRDD Java API method should acc...Bryan Cutler2015-11-181-1/+23
* [SPARK-11761] Prevent the call to StreamingContext#stop() in the listener bus...tedyu2015-11-171-1/+5
* [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batchShixiong Zhu2015-11-171-2/+16
* [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-161-1/+1
* [SPARK-11681][STREAMING] Correctly update state timestamp even when state is ...Tathagata Das2015-11-121-44/+61
* [SPARK-11419][STREAMING] Parallel recovery for FileBasedWriteAheadLog + minor...Burak Yavuz2015-11-125-31/+96
* [SPARK-11663][STREAMING] Add Java API for trackStateByKeyShixiong Zhu2015-11-127-27/+183
* [SPARK-11639][STREAMING][FLAKY-TEST] Implement BlockingWriteAheadLog for test...Burak Yavuz2015-11-111-0/+3
* [SPARK-11290][STREAMING] Basic implementation of trackStateByKeyTathagata Das2015-11-106-4/+1114
* [SPARK-11361][STREAMING] Show scopes of RDD operations inside DStream.foreach...Tathagata Das2015-11-103-14/+76
* [SPARK-11333][STREAMING] Add executorId to ReceiverInfo and display it in UIShixiong Zhu2015-11-095-2/+10
* [SPARK-11462][STREAMING] Add JavaStreamingListenerzsxwing2015-11-092-0/+290
* [SPARK-11141][STREAMING] Batch ReceivedBlockTrackerLogEvents for WAL writesBurak Yavuz2015-11-094-25/+306
* [SPARK-11511][STREAMING] Fix NPE when an InputDStream is not usedShixiong Zhu2015-11-061-1/+2
* [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-274-88/+129
* [SPARK-11324][STREAMING] Flag for closing Write Ahead Logs after a writeBurak Yavuz2015-10-272-2/+19
* [SPARK-5569][STREAMING] fix ObjectInputStreamWithLoader for supporting load a...maxwell2015-10-271-1/+3
* [SPARK-11063] [STREAMING] Change preferredLocations of Receiver's RDD to host...zsxwing2015-10-192-2/+5
* [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-1611-181/+230
* [SPARK-11060] [STREAMING] Fix some potential NPE in DStream transformationjerryshao2015-10-164-9/+17
* [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-101-2/+10
* [SPARK-10955] [STREAMING] Add a warning if dynamic allocation for Streaming a...Hari Shreedharan2015-10-081-1/+8
* [SPARK-10885] [STREAMING] Display the failed output op in Streaming UIzsxwing2015-10-065-25/+141
* [SPARK-10900] [STREAMING] Add output operation events to StreamingListenerzsxwing2015-10-056-9/+88
* 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
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-18 09:54:53 +0000