aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [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
* [SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests.py.Marcelo Vanzin2015-09-151-10/+0
* Update version to 1.6.0-SNAPSHOT.Reynold Xin2015-09-151-1/+1
* [SPARK-10576] [BUILD] Move .java files out of src/main/scalaSean Owen2015-09-141-0/+0
* [SPARK-10547] [TEST] Streamline / improve style of Java API testsSean Owen2015-09-122-425/+413
* [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-083-13/+30
* [SPARK-9767] Remove ConnectionManager.Reynold Xin2015-09-071-4/+6
* [SPARK-10311] [STREAMING] Reload appId and attemptId when app starts with che...xutingjun2015-09-041-0/+2
* [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-312-2/+53
* [SPARK-9613] [CORE] Ban use of JavaConversions and migrate all existing uses ...Sean Owen2015-08-2510-68/+55
* [SPARK-10210] [STREAMING] Filter out non-existent blocks before creating Bloc...Tathagata Das2015-08-253-2/+166
* [SPARK-10137] [STREAMING] Avoid to restart receivers if scheduleReceivers ret...zsxwing2015-08-243-57/+120
* [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
* [SPARK-10098] [STREAMING] [TEST] Cleanup active context after test in Failure...Tathagata Das2015-08-181-10/+17
* [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-143-42/+87
* [SPARK-9826] [CORE] Fix cannot use custom classes in log4j.propertiesMichel Lemay2015-08-121-4/+4
* [SPARK-9801] [STREAMING] Check if file exists before deleting temporary files.Hao Zhu2015-08-101-2/+6
* Disable JobGeneratorSuite "Do not clear received block data too soon".Reynold Xin2015-08-091-1/+2
* [SPARK-9639] [STREAMING] Fix a potential NPE in Streaming JobSchedulerzsxwing2015-08-061-10/+22
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-21 05:44:46 +0000