aboutsummaryrefslogtreecommitdiff
path: root/external
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-20189][DSTREAM] Fix spark kinesis testcases to remove deprecated creat...Yash Sharma2017-04-132-22/+38
* [SPARK-20156][CORE][SQL][STREAMING][MLLIB] Java String toLowerCase "Turkish l...Sean Owen2017-04-106-30/+38
* [SPARK-20209][SS] Execute next trigger immediately if previous batch took lon...Tathagata Das2017-04-041-0/+1
* [SPARK-19911][STREAMING] Add builder interface for Kinesis DStreamsAdam Budde2017-03-2411-149/+749
* [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-19304][STREAMING][KINESIS] fix kinesis slow checkpoint recoveryGaurav2017-03-064-11/+25
* [MINOR][BUILD] Fix lint-java breaks in Javahyukjinkwon2017-02-272-3/+2
* [SPARK-19405][STREAMING] Support for cross-account Kinesis reads via STSAdam Budde2017-02-2215-80/+394
* [SPARK-18922][TESTS] Fix new test failures on Windows due to path and resourc...hyukjinkwon2017-02-202-9/+15
* [SPARK-19534][TESTS] Convert Java tests to use lambdas, Java 8 featuresSean Owen2017-02-191-12/+12
* [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-169-1519/+2
* [SPARK-19318][SQL] Fix to treat JDBC connection properties specified by the u...sureshthalamati2017-02-141-0/+36
* [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-18020][STREAMING][KINESIS] Checkpoint SHARD_END to finish reading clos...Takeshi YAMAMURO2017-01-255-7/+116
* [SPARK-14536][SQL] fix to handle null value in array type column for postgres.sureshthalamati2017-01-201-2/+10
* [SPARK-19227][SPARK-19251] remove unused imports and outdated commentsuncleGen2017-01-186-7/+5
* [SPARK-19206][DOC][DSTREAM] Fix outdated parameter descriptions in kafka010uncleGen2017-01-153-25/+16
* [SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...hyukjinkwon2017-01-106-29/+91
* [MINOR][DOCS] Remove consecutive duplicated words/typo in Spark RepoNiranjan Padmanabhan2017-01-043-3/+3
* [SPARK-17807][CORE] split test-tags into test-JARRyan Williams2016-12-218-1/+85
* [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-18620][STREAMING][KINESIS] Flatten input rates in timeline for streami...Takeshi YAMAMURO2016-12-103-2/+35
* [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
generated by cgit v1.2.3 (git 2.39.1) at 2024-05-04 19:45:16 +0000