aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
...
* [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
* [SPARK-10692] [STREAMING] Expose failureReasons in BatchInfo for streaming UI...zsxwing2015-09-233-16/+39
* [SPARK-6028][Core]A new RPC implemetation based on the network modulezsxwing2015-09-231-1/+1
* [SPARK-10224] [STREAMING] Fix the issue that blockIntervalTimer won't call up...zsxwing2015-09-231-6/+13
* [SPARK-10652] [SPARK-10742] [STREAMING] Set meaningful job descriptions for a...Tathagata Das2015-09-224-16/+41
* [SPARK-10649] [STREAMING] Prevent inheriting job group and irrelevant job des...Tathagata Das2015-09-211-3/+12
* [SPARK-10576] [BUILD] Move .java files out of src/main/scalaSean Owen2015-09-141-0/+0
* [SPARK-10227] fatal warnings with sbt on Scala 2.11Luc Bourlier2015-09-0910-26/+26
* [SPARK-10071] [STREAMING] Output a warning when writing QueueInputDStream and...zsxwing2015-09-082-4/+11
* [SPARK-10311] [STREAMING] Reload appId and attemptId when app starts with che...xutingjun2015-09-041-0/+2
* [SPARK-10369] [STREAMING] Don't remove ReceiverTrackingInfo when deregisterRe...zsxwing2015-08-311-2/+2
* [SPARK-9613] [CORE] Ban use of JavaConversions and migrate all existing uses ...Sean Owen2015-08-258-49/+46
* [SPARK-10210] [STREAMING] Filter out non-existent blocks before creating Bloc...Tathagata Das2015-08-252-2/+10
* [SPARK-10137] [STREAMING] Avoid to restart receivers if scheduleReceivers ret...zsxwing2015-08-242-51/+113
* [SPARK-9791] [PACKAGE] Change private class to private class to prevent unnec...Tathagata Das2015-08-245-3/+7
* [SPARK-10142] [STREAMING] Made python checkpoint recovery handle non-local ch...Tathagata Das2015-08-231-0/+9
* [SPARK-10148] [STREAMING] Display active and inactive receiver numbers in Str...zsxwing2015-08-232-0/+14
* [SPARK-10128] [STREAMING] Used correct classloader to deserialize WAL dataTathagata Das2015-08-191-2/+3
* [SPARK-10125] [STREAMING] Fix a potential deadlock in JobGenerator.stopzsxwing2015-08-191-0/+4
* [SPARK-9967] [SPARK-10099] [STREAMING] Renamed conf spark.streaming.backpress...Tathagata Das2015-08-182-6/+6
* [SPARK-10102] [STREAMING] Fix a race condition that startReceiver may happen ...zsxwing2015-08-181-3/+8
* [SPARK-10072] [STREAMING] BlockGenerator can deadlock when the queue of gener...Tathagata Das2015-08-181-10/+19
* [HOTFIX] fix duplicated bracesDavies Liu2015-08-142-2/+2
* [SPARK-9968] [STREAMING] Reduced time spent within synchronized block to prev...Tathagata Das2015-08-141-8/+32
* [SPARK-9966] [STREAMING] Handle couple of corner cases in PIDRateEstimatorTathagata Das2015-08-142-14/+36
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-21 20:18:31 +0000