aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-18692][BUILD][DOCS] Test Java 8 unidoc build on Jenkinshyukjinkwon2017-04-123-4/+4
* [SPARK-20156][CORE][SQL][STREAMING][MLLIB] Java String toLowerCase "Turkish l...Sean Owen2017-04-104-7/+11
* [DOCS] Docs-only improvementsJacek Laskowski2017-03-301-1/+1
* [SPARK-19556][CORE] Do not encrypt block manager data in memory.Marcelo Vanzin2017-03-294-16/+9
* [SPARK-19820][CORE] Add interface to kill tasks w/ a reasonEric Liang2017-03-232-2/+2
* [DOCS][SS] fix structured streaming python exampleuncleGen2017-03-121-1/+1
* [SPARK-19822][TEST] CheckpointSuite.testCheckpointedOperation: should not fil...uncleGen2017-03-051-3/+1
* [MINOR][BUILD] Fix lint-java breaks in Javahyukjinkwon2017-02-273-32/+44
* [SPARK-19652][UI] Do auth checks for REST API access.Marcelo Vanzin2017-02-211-4/+4
* [SPARK-19646][CORE][STREAMING] binaryRecords replicates records in scala APISean Owen2017-02-202-13/+13
* [SPARK-19534][TESTS] Convert Java tests to use lambdas, Java 8 featuresSean Owen2017-02-195-500/+162
* [SPARK-19450] Replace askWithRetry with askSync.jinxing2017-02-192-5/+5
* [SPARK-19550][BUILD][CORE][WIP] Remove Java 7 supportSean Owen2017-02-162-1/+896
* [SPARK-19520][STREAMING] Do not encrypt data written to the WAL.Marcelo Vanzin2017-02-134-21/+69
* [SPARK-19347] ReceiverSupervisorImpl can add block to ReceiverTracker multipl...jinxing2017-02-011-1/+1
* [SPARK-19402][DOCS] Support LaTex inline formula correctly and fix warnings i...hyukjinkwon2017-02-011-1/+1
* [SPARK-19330][DSTREAMS] Also show tooltip for successful batchesLiwei Lin2017-01-241-2/+2
* [SPARK-19182][DSTREAM] Optimize the lock in StreamingJobProgressListener to n...uncleGen2017-01-182-8/+13
* [SPARK-18905][STREAMING] Fix the issue of removing a failed jobset from JobSc...CodingCat2017-01-161-6/+8
* [SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...hyukjinkwon2017-01-102-3/+17
* [MINOR][DOCS] Remove consecutive duplicated words/typo in Spark RepoNiranjan Padmanabhan2017-01-045-6/+6
* [SPARK-18537][WEB UI] Add a REST api to serve spark streaming informationsaturday_s2016-12-2222-4/+676
* [FLAKY-TEST] InputStreamsSuite.socket input streamBurak Yavuz2016-12-211-32/+23
* [SPARK-17807][CORE] split test-tags into test-JARRyan Williams2016-12-211-0/+11
* [SPARK-18954][TESTS] Fix flaky test: o.a.s.streaming.BasicOperationsSuite rdd...Shixiong Zhu2016-12-212-44/+73
* [SPARK-18031][TESTS] Fix flaky test ExecutorAllocationManagerSuite.basic func...Shixiong Zhu2016-12-211-4/+32
* [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