aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-17638][STREAMING] Stop JVM StreamingContext when the Python process is...Shixiong Zhu2016-09-223-2/+35
* [SPARK-17365][CORE] Remove/Kill multiple executors together to reduce RPC cal...Dhruve Ashar2016-09-222-2/+9
* [SPARK-17359][SQL][MLLIB] Use ArrayBuffer.+=(A) instead of ArrayBuffer.append...Liwei Lin2016-09-071-1/+1
* [SPARK-17110] Fix StreamCorruptionException in BlockManager.getRemoteValues()Josh Rosen2016-09-061-2/+3
* [SPARK-17308] Improved the spark core code by replacing all pattern match on ...Shivansh2016-09-041-3/+4
* [SPARK-17038][STREAMING] fix metrics retrieval source of 'lastReceivedBatch'Xin Ren2016-08-171-3/+3
* [SPARK-16736][CORE][SQL] purge superfluous fs callsSteve Loughran2016-08-173-30/+38
* [SPARK-15869][STREAMING] Fix a potential NPE in StreamingJobProgressListener....Shixiong Zhu2016-08-011-1/+1
* [SPARK-16416][CORE] force eager creation of loggers to avoid shutdown hook co...Mikael Ståldal2016-07-241-0/+1
* [SPARK-16487][STREAMING] Fix some batches might not get marked as fully proce...Ahmed Mahran2016-07-221-1/+3
* [SPARK-16395][STREAMING] Fail if too many CheckpointWriteHandlers are queued ...Sean Owen2016-07-191-3/+10
* [SPARK-16129][CORE][SQL] Eliminate direct use of commons-lang classes in favo...Sean Owen2016-06-242-7/+4
* [SPARK-15875] Try to use Seq.isEmpty and Seq.nonEmpty instead of Seq.length =...wangyang2016-06-101-1/+1
* [MINOR][X][X] Replace all occurrences of None: Option with Option.emptySandeep Singh2016-06-101-1/+1
* [MINOR] Fix Typos 'an -> a'Zheng RuiFeng2016-06-065-8/+8
* [SPARK-15748][SQL] Replace inefficient foldLeft() call with flatMap() in Part...Josh Rosen2016-06-051-2/+2
* [SPARK-10530][CORE] Kill other task attempts when one taskattempt belonging t...Devaraj K2016-05-302-0/+2
* [SPARK-15645][STREAMING] Fix some typos of Streaming moduleXin Ren2016-05-305-10/+9
* [MINOR] Fix Typos 'a -> an'Zheng RuiFeng2016-05-267-11/+11
* [MINOR][MLLIB][STREAMING][SQL] Fix typoslfzCarlosC2016-05-251-1/+1
* [SPARK-14976][STREAMING] make StreamingContext.textFileStream support wildcardmwws2016-05-111-2/+8
* [SPARK-15152][DOC][MINOR] Scaladoc and Code style ImprovementsJacek Laskowski2016-05-051-24/+25
* [SPARK-9819][STREAMING][DOCUMENTATION] Clarify doc for invReduceFunc in incre...François Garillot2016-05-034-4/+8
* [SPARK-14930][SPARK-13693] Fix race condition in CheckpointWriter.stop()Josh Rosen2016-04-271-12/+5
* [MINOR][DOCS] Minor typo fixesJacek Laskowski2016-04-261-2/+2
* [SPARK-14868][BUILD] Enable NewLineAtEofChecker in checkstyle and fix lint-ja...Dongjoon Hyun2016-04-242-2/+2
* [SPARK-14701][STREAMING] First stop the event loop, then stop the checkpoint ...Liwei Lin2016-04-221-2/+2
* [SPARK-6429] Implement hashCode and equals togetherJoan2016-04-221-3/+7
* [SPARK-8393][STREAMING] JavaStreamingContext#awaitTermination() throws non-de...Sean Owen2016-04-211-0/+2
* Revert "[SPARK-14719] WriteAheadLogBasedBlockHandler should ignore BlockManag...Josh Rosen2016-04-191-14/+8
* [SPARK-14676] Wrap and re-throw Await.result exceptions in order to capture f...Josh Rosen2016-04-192-5/+6
* [SPARK-14719] WriteAheadLogBasedBlockHandler should ignore BlockManager put e...Josh Rosen2016-04-181-8/+14
* [MINOR] Remove inappropriate type notation and extra anonymous closure within...hyukjinkwon2016-04-161-8/+8
* [SPARK-14630][BUILD][CORE][SQL][STREAMING] Code style: public abstract method...Liwei Lin2016-04-145-14/+14
* [MINOR][SQL] Remove extra anonymous closure within functional transformationshyukjinkwon2016-04-143-8/+8
* [SPARK-14508][BUILD] Add a new ScalaStyle Rule `OmitBracesInCase`Dongjoon Hyun2016-04-124-24/+11
* [SPARK-14475] Propagate user-defined context from driver to executorsEric Liang2016-04-113-7/+15
* [SPARK-14455][STREAMING] Fix NPE in allocatedExecutors when calling in receiv...jerryshao2016-04-091-3/+9
* [SPARK-12133][STREAMING] Streaming dynamic allocationTathagata Das2016-04-064-3/+270
* [SPARK-13211][STREAMING] StreamingContext throws NoSuchElementException when ...Sean Owen2016-04-052-9/+5
* [SPARK-12425][STREAMING] DStream union optimisationGuillaume Poulin2016-04-052-11/+4
* [SPARK-14358] Change SparkListener from a trait to an abstract classReynold Xin2016-04-041-1/+1
* [MINOR][DOCS] Use multi-line JavaDoc comments in Scala code.Dongjoon Hyun2016-04-024-20/+24
* [MINOR] Typo fixesJacek Laskowski2016-04-029-36/+39
* [SPARK-12857][STREAMING] Standardize "records" and "events" on "records"Liwei Lin2016-04-014-40/+41
* [SPARK-13992] Add support for off-heap cachingJosh Rosen2016-04-011-1/+2
* [SPARK-14075] Refactor MemoryStore to be testable independent of BlockManagerJosh Rosen2016-03-233-4/+7
* [SPARK-13990] Automatically pick serializer when caching RDDsJosh Rosen2016-03-211-1/+2
* [SPARK-13921] Store serialized blocks as multiple chunks in MemoryStoreJosh Rosen2016-03-172-7/+13
* [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.internal.Lo...Wenchen Fan2016-03-1727-25/+41
generated by cgit v1.2.3 (git 2.39.1) at 2024-08-12 04:18:53 +0000