aboutsummaryrefslogtreecommitdiff
path: root/external/kafka-0-10-sql/src
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-20156][CORE][SQL][STREAMING][MLLIB] Java String toLowerCase "Turkish l...Sean Owen2017-04-104-25/+30
* [SPARK-20209][SS] Execute next trigger immediately if previous batch took lon...Tathagata Das2017-04-041-0/+1
* [SPARK-19876][SS][WIP] OneTime Trigger ExecutorTyson Condie2017-03-231-2/+0
* [SPARK-19721][SS] Good error message for version mismatch in log filesLiwei Lin2017-03-162-9/+14
* [SPARK-19853][SS] uppercase kafka topics fail when startingOffsets are Specif...uncleGen2017-03-122-34/+54
* [SPARK-19886] Fix reportDataLoss if statement in SS KafkaSourceBurak Yavuz2017-03-092-13/+54
* [SPARK-19719][SS] Kafka writer for both structured streaming and batch queiresTyson Condie2017-03-065-5/+753
* [SPARK-18922][TESTS] Fix new test failures on Windows due to path and resourc...hyukjinkwon2017-02-202-9/+15
* [SPARK-19617][SS] Fix the race condition when starting and stopping a query q...Shixiong Zhu2017-02-171-1/+1
* [SPARK-19517][SS] KafkaSource fails to initialize partition offsetsRoberto Agostino Vitillo2017-02-173-7/+130
* [SPARK-19550][BUILD][CORE][WIP] Remove Java 7 supportSean Owen2017-02-161-2/+1
* [SPARK-19564][SPARK-19559][SS][KAFKA] KafkaOffsetReader's consumers should no...Liwei Lin2017-02-121-4/+7
* [SPARK-18682][SS] Batch Source for KafkaTyson Condie2017-02-0712-430/+1180
* [SPARK-19227][SPARK-19251] remove unused imports and outdated commentsuncleGen2017-01-181-1/+1
* [SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...hyukjinkwon2017-01-101-4/+28
* [MINOR][DOCS] Remove consecutive duplicated words/typo in Spark RepoNiranjan Padmanabhan2017-01-041-1/+1
* [SPARK-18588][SS][KAFKA] Create a new KafkaConsumer when error happens to fix...Shixiong Zhu2016-12-213-31/+50
* [SPARK-18588][TESTS] Ignore KafkaSourceStressForDontFailOnDataLossSuiteShixiong Zhu2016-12-131-1/+1
* [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-18516][SQL] Split state and progress in streamingTathagata Das2016-11-291-3/+4
* [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-191-1/+1
* [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-031-1/+4
* [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-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-17346][SQL][TESTS] Fix the flaky topic deletion in KafkaSourceStressSuiteShixiong Zhu2016-10-111-8/+1
* [SPARK-17346][SQL][TEST-MAVEN] Generate the sql test jar to fix the maven buildShixiong Zhu2016-10-051-0/+1
* [SPARK-17346][SQL] Add Kafka source for Structured StreamingShixiong Zhu2016-10-0511-0/+1887
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-17 04:06:05 +0000