aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-18695] Bump master branch version to 2.2.0-SNAPSHOTReynold Xin2016-12-021-1/+1
* [SPARK-18617][SPARK-18560][TESTS] Fix flaky test: StreamingContextSuite. Rece...Shixiong Zhu2016-12-011-1/+3
* [SPARK-18617][SPARK-18560][TEST] Fix flaky test: StreamingContextSuite. Recei...Shixiong Zhu2016-11-301-26/+8
* [SPARK-18617][CORE][STREAMING] Close "kryo auto pick" feature for Spark Strea...uncleGen2016-11-291-0/+47
* [SPARK-18615][DOCS] Switch to multi-line doc to avoid a genjavadoc bug for ba...hyukjinkwon2016-11-291-2/+6
* [SPARK-3359][DOCS] Make javadoc8 working for unidoc/genjavadoc compatibility ...hyukjinkwon2016-11-294-7/+7
* [SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...hyukjinkwon2016-11-196-33/+35
* [SPARK-18423][STREAMING] ReceiverTracker should close checkpoint dir when sto...hyukjinkwon2016-11-151-0/+10
* [SPARK-13027][STREAMING] Added batch time as a parameter to updateStateByKeyAaditya Ramesh2016-11-154-20/+126
* [SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and e...wm624@hotmail.com2016-11-102-0/+2
* [SPARK-18191][CORE] Port RDD API to use commit protocoljiangxingbo2016-11-082-4/+6
* [SPARK-14914][CORE] Fix Resource not closed after using, mostly for unit testsHyukjin Kwon2016-11-075-7/+17
* [SPARK-18076][CORE][SQL] Fix default Locale used in DateFormat, NumberFormat ...Sean Owen2016-11-021-3/+5
* [SPARK-18204][WEBUI] Remove SparkUI.appUIAddressJacek Laskowski2016-11-021-6/+6
* [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-223-4/+12
* [SPARK-4563][CORE] Allow driver to advertise a different network address.Marcelo Vanzin2016-09-212-2/+4
* [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-062-3/+5
* [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-172-3/+6
* [SPARK-16736][CORE][SQL] purge superfluous fs callsSteve Loughran2016-08-173-30/+38
* [SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add mu...Holden Karau2016-08-081-1/+0
* [SPARK-15869][STREAMING] Fix a potential NPE in StreamingJobProgressListener....Shixiong Zhu2016-08-011-1/+1
* [SPARK-16694][CORE] Use for/foreach rather than map for Unit expressions whos...Sean Owen2016-07-301-1/+1
* [SPARK-15703][SCHEDULER][CORE][WEBUI] Make ListenerBus event queue size confi...Dhruve Ashar2016-07-261-1/+4
* [SPARK-16722][TESTS] Fix a StreamingContext leak in StreamingContextSuite whe...Shixiong Zhu2016-07-251-3/+6
* [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-16535][BUILD] In pom.xml, remove groupId which is redundant definition...Xin Ren2016-07-191-1/+0
* [SPARK-16477] Bump master version to 2.1.0-SNAPSHOTReynold Xin2016-07-111-1/+1
* [SPARK-16129][CORE][SQL] Eliminate direct use of commons-lang classes in favo...Sean Owen2016-06-242-7/+4
* [SPARK-16120][STREAMING] getCurrentLogFiles in ReceiverSuite WAL generating a...Ahmed Mahran2016-06-221-1/+1
* [SPARK-15086][CORE][STREAMING] Deprecate old Java accumulator APISean Owen2016-06-121-3/+3
* [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-067-10/+10
* [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-15290][BUILD] Move annotations, like @Since / @DeveloperApi, into spar...Sean Owen2016-05-171-1/+1
* [SPARK-12972][CORE] Update org.apache.httpcomponents.httpclientSean Owen2016-05-151-0/+5
* [SPARK-14897][SQL] upgrade to jetty 9.2.16bomeng2016-05-121-0/+4
* [SPARK-14976][STREAMING] make StreamingContext.textFileStream support wildcardmwws2016-05-112-2/+70
* [MINOR][TEST][STREAMING] make "testDir" able to be claened after test.mwws2016-05-091-4/+4
* [SPARK-1239] Improve fetching of map output statusesThomas Graves2016-05-061-1/+3
* [SPARK-15152][DOC][MINOR] Scaladoc and Code style ImprovementsJacek Laskowski2016-05-051-24/+25
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-01 01:32:08 +0000