aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-3873][STREAMING] Import order fixes for streaming.Marcelo Vanzin2015-12-3153-125/+126
* [SPARK-12311][CORE] Restore previous value of "os.arch" property in test suit...Kazuaki Ishizaki2015-12-249-21/+70
* [MINOR] Fix typos in JavaStreamingContextShixiong Zhu2015-12-211-4/+4
* Bump master version to 2.0.0-SNAPSHOT.Reynold Xin2015-12-191-1/+1
* [SPARK-11749][STREAMING] Duplicate creating the RDD in file stream when recov...jhu-chang2015-12-172-9/+62
* [SPARK-12410][STREAMING] Fix places that use '.' and '|' directly in splitShixiong Zhu2015-12-171-1/+1
* [SPARK-12304][STREAMING] Make Spark Streaming web UI display more fri…proflin2015-12-151-1/+7
* [STREAMING][MINOR] Fix typo in function name of StateImpljerryshao2015-12-153-3/+3
* [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-0910-358/+367
* [SPARK-11932][STREAMING] Partition previous TrackStateRDD if partitioner not ...Tathagata Das2015-12-076-84/+258
* [SPARK-12106][STREAMING][FLAKY-TEST] BatchedWAL test transiently flaky when J...Burak Yavuz2015-12-072-6/+14
* [SPARK-12084][CORE] Fix codes that uses ByteBuffer.array incorrectlyShixiong Zhu2015-12-044-30/+19
* [SPARK-6990][BUILD] Add Java linting script; fix minor warningsDmitry Erastov2015-12-043-8/+8
* [SPARK-12122][STREAMING] Prevent batches from being submitted twice after rec...Tathagata Das2015-12-041-1/+2
* [FLAKY-TEST-FIX][STREAMING][TEST] Make sure StreamingContexts are shutdown af...Tathagata Das2015-12-031-61/+61
* [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-12021][STREAMING][TESTS] Fix the potential dead-lock in StreamingListe...Shixiong Zhu2015-11-271-6/+19
* [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-243-17/+42
* [STREAMING][FLAKY-TEST] Catch execution context race condition in `FileBasedW...Burak Yavuz2015-11-241-5/+11
* [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
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-26 21:28:39 +0000