aboutsummaryrefslogtreecommitdiff
path: root/external
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-18776][SS] Make Offset for FileStreamSource corrected formatted in jsonTathagata Das2016-12-081-1/+1
* [SPARK-18754][SS] Rename recentProgresses to recentProgressMichael Armbrust2016-12-071-1/+1
* [SPARK-18588][TESTS] Fix flaky test: KafkaSourceStressForDontFailOnDataLossSuiteShixiong Zhu2016-12-074-37/+90
* [SPARK-18671][SS][TEST-MAVEN] Follow up PR to fix test for MavenTathagata Das2016-12-062-1/+3
* [SPARK-18671][SS][TEST] Added tests to ensure stability of that all Structure...Tathagata Das2016-12-062-1/+20
* [SPARK-18695] Bump master branch version to 2.2.0-SNAPSHOTReynold Xin2016-12-0213-13/+13
* [SPARK-18516][SQL] Split state and progress in streamingTathagata Das2016-11-291-3/+4
* [SPARK-3359][DOCS] Make javadoc8 working for unidoc/genjavadoc compatibility ...hyukjinkwon2016-11-295-16/+28
* [SPARK-18588][SS][KAFKA] Ignore the flaky kafka testShixiong Zhu2016-11-281-1/+1
* [SPARK-18530][SS][KAFKA] Change Kafka timestamp column type to TimestampTypeShixiong Zhu2016-11-222-4/+93
* [SPARK-18373][SPARK-18529][SS][KAFKA] Make failOnDataLoss=false work with Spa...Shixiong Zhu2016-11-225-95/+523
* [SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...hyukjinkwon2016-11-194-38/+34
* [SPARK-18400][STREAMING] NPE when resharding Kinesis StreamSean Owen2016-11-161-19/+23
* [SPARK-17510][STREAMING][KAFKA] config max rate on a per-partition basiscody koeninger2016-11-145-18/+131
* [SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and e...wm624@hotmail.com2016-11-103-0/+5
* [SPARK-17829][SQL] Stable format for offset logTyson Condie2016-11-094-8/+82
* [SPARK-18283][STRUCTURED STREAMING][KAFKA] Added test to check whether defaul...Tathagata Das2016-11-071-0/+24
* [SPARK-18212][SS][KAFKA] increase executor poll timeoutcody koeninger2016-11-032-2/+6
* [SPARK-17813][SQL][KAFKA] Maximum data per triggercody koeninger2016-10-272-27/+151
* [SPARK-17812][SQL][KAFKA] Assign and specific startingOffsets for structured ...cody koeninger2016-10-217-45/+369
* [SPARK-17999][KAFKA][SQL] Add getPreferredLocations for KafkaSourceRDDjerryshao2016-10-201-0/+5
* [SPARK-17841][STREAMING][KAFKA] drain commitQueuecody koeninger2016-10-181-3/+3
* [SPARK-17731][SQL][STREAMING] Metrics for structured streamingTathagata Das2016-10-131-0/+27
* [SPARK-17834][SQL] Fetch the earliest offsets manually in KafkaSource instead...Shixiong Zhu2016-10-132-26/+48
* [SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll ...cody koeninger2016-10-123-7/+32
* [SPARK-17346][SQL][TESTS] Fix the flaky topic deletion in KafkaSourceStressSuiteShixiong Zhu2016-10-111-8/+1
* [SPARK-17803][TESTS] Upgrade docker-client dependencyChristian Kadner2016-10-061-0/+1
* [SPARK-17346][SQL][TEST-MAVEN] Generate the sql test jar to fix the maven buildShixiong Zhu2016-10-052-0/+15
* [SPARK-17346][SQL] Add Kafka source for Structured StreamingShixiong Zhu2016-10-0512-0/+1969
* [SPARK-17418] Prevent kinesis-asl-assembly artifacts from being publishedJosh Rosen2016-09-211-0/+15
* [SPARK-17473][SQL] fixing docker integration tests error due to different ver...sureshthalamati2016-09-191-68/+0
* [SPARK-17534][TESTS] Increase timeouts for DirectKafkaStreamSuite testsAdam Roberts2016-09-161-4/+4
* [SPARK-17359][SQL][MLLIB] Use ArrayBuffer.+=(A) instead of ArrayBuffer.append...Liwei Lin2016-09-071-11/+11
* [SPARK-17229][SQL] PostgresDialect shouldn't widen float and short types duri...Josh Rosen2016-08-251-4/+18
* [SPARK-17023][BUILD] Upgrade to Kafka 0.10.0.1 releaseLuciano Resende2016-08-131-1/+1
* [SPARK-16950] [PYSPARK] fromOffsets parameter support in KafkaUtils.createDir...Mariusz Strzelecki2016-08-091-4/+4
* [SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add mu...Holden Karau2016-08-082-4/+0
* [SPARK-13238][CORE] Add ganglia dmax parameterEkasit Kijsipongse2016-08-051-0/+5
* [SPARK-16625][SQL] General data types to be mapped to OracleYuming Wang2016-08-051-1/+73
* [SPARK-16776][STREAMING] Replace deprecated API in KafkaTestUtils for 0.10.0.hyukjinkwon2016-08-011-8/+12
* [TEST][STREAMING] Fix flaky Kafka rate controlling testTathagata Das2016-07-261-5/+4
* [SPARK-16535][BUILD] In pom.xml, remove groupId which is redundant definition...Xin Ren2016-07-1911-11/+0
* [SPARK-16477] Bump master version to 2.1.0-SNAPSHOTReynold Xin2016-07-1112-12/+12
* [SPARK-13569][STREAMING][KAFKA] pattern based topic subscriptioncody koeninger2016-07-083-9/+258
* [SPARK-16212][STREAMING][KAFKA] apply test tweaks from 0-10 to 0-8 as wellcody koeninger2016-07-062-25/+24
* [SPARK-16212][STREAMING][KAFKA] use random port for embedded kafkacody koeninger2016-07-051-2/+4
* [SPARK-12177][STREAMING][KAFKA] limit api surface areacody koeninger2016-07-0113-193/+222
* [SPARK-16212][STREAMING][KAFKA] code cleanup from review feedbackcody koeninger2016-06-303-14/+12
* [SPARK-12177][TEST] Removed test to avoid compilation issue in scala 2.10Tathagata Das2016-06-301-4/+4
* [SPARK-12177][STREAMING][KAFKA] Update KafkaDStreams to new Kafka 0.10 Consum...cody koeninger2016-06-2920-0/+3351
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-01 02:42:24 +0000