index
:
spark
2.12/build
SPARK-10001-hotfix
SPARK-10001-sigint
SPARK-14511-genjavadoc
SPARK-17647
WIP-SPARK-17647
escape
genjavadoc
macros
master
packages
scala-2.12
value-classes
Mirror of Apache Spark
about
summary
refs
log
tree
commit
diff
log msg
author
committer
range
path:
root
/
external
Commit message (
Expand
)
Author
Age
Files
Lines
*
[SPARK-19911][STREAMING] Add builder interface for Kinesis DStreams
Adam Budde
2017-03-24
11
-149
/
+749
*
[SPARK-19876][SS][WIP] OneTime Trigger Executor
Tyson Condie
2017-03-23
1
-2
/
+0
*
[SPARK-19721][SS] Good error message for version mismatch in log files
Liwei Lin
2017-03-16
2
-9
/
+14
*
[SPARK-19853][SS] uppercase kafka topics fail when startingOffsets are Specif...
uncleGen
2017-03-12
2
-34
/
+54
*
[SPARK-19886] Fix reportDataLoss if statement in SS KafkaSource
Burak Yavuz
2017-03-09
2
-13
/
+54
*
[SPARK-19719][SS] Kafka writer for both structured streaming and batch queires
Tyson Condie
2017-03-06
5
-5
/
+753
*
[SPARK-19304][STREAMING][KINESIS] fix kinesis slow checkpoint recovery
Gaurav
2017-03-06
4
-11
/
+25
*
[MINOR][BUILD] Fix lint-java breaks in Java
hyukjinkwon
2017-02-27
2
-3
/
+2
*
[SPARK-19405][STREAMING] Support for cross-account Kinesis reads via STS
Adam Budde
2017-02-22
15
-80
/
+394
*
[SPARK-18922][TESTS] Fix new test failures on Windows due to path and resourc...
hyukjinkwon
2017-02-20
2
-9
/
+15
*
[SPARK-19534][TESTS] Convert Java tests to use lambdas, Java 8 features
Sean Owen
2017-02-19
1
-12
/
+12
*
[SPARK-19617][SS] Fix the race condition when starting and stopping a query q...
Shixiong Zhu
2017-02-17
1
-1
/
+1
*
[SPARK-19517][SS] KafkaSource fails to initialize partition offsets
Roberto Agostino Vitillo
2017-02-17
3
-7
/
+130
*
[SPARK-19550][BUILD][CORE][WIP] Remove Java 7 support
Sean Owen
2017-02-16
9
-1519
/
+2
*
[SPARK-19318][SQL] Fix to treat JDBC connection properties specified by the u...
sureshthalamati
2017-02-14
1
-0
/
+36
*
[SPARK-19564][SPARK-19559][SS][KAFKA] KafkaOffsetReader's consumers should no...
Liwei Lin
2017-02-12
1
-4
/
+7
*
[SPARK-18682][SS] Batch Source for Kafka
Tyson Condie
2017-02-07
12
-430
/
+1180
*
[SPARK-18020][STREAMING][KINESIS] Checkpoint SHARD_END to finish reading clos...
Takeshi YAMAMURO
2017-01-25
5
-7
/
+116
*
[SPARK-14536][SQL] fix to handle null value in array type column for postgres.
sureshthalamati
2017-01-20
1
-2
/
+10
*
[SPARK-19227][SPARK-19251] remove unused imports and outdated comments
uncleGen
2017-01-18
6
-7
/
+5
*
[SPARK-19206][DOC][DSTREAM] Fix outdated parameter descriptions in kafka010
uncleGen
2017-01-15
3
-25
/
+16
*
[SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...
hyukjinkwon
2017-01-10
6
-29
/
+91
*
[MINOR][DOCS] Remove consecutive duplicated words/typo in Spark Repo
Niranjan Padmanabhan
2017-01-04
3
-3
/
+3
*
[SPARK-17807][CORE] split test-tags into test-JAR
Ryan Williams
2016-12-21
8
-1
/
+85
*
[SPARK-18588][SS][KAFKA] Create a new KafkaConsumer when error happens to fix...
Shixiong Zhu
2016-12-21
3
-31
/
+50
*
[SPARK-18588][TESTS] Ignore KafkaSourceStressForDontFailOnDataLossSuite
Shixiong Zhu
2016-12-13
1
-1
/
+1
*
[SPARK-18620][STREAMING][KINESIS] Flatten input rates in timeline for streami...
Takeshi YAMAMURO
2016-12-10
3
-2
/
+35
*
[SPARK-18776][SS] Make Offset for FileStreamSource corrected formatted in json
Tathagata Das
2016-12-08
1
-1
/
+1
*
[SPARK-18754][SS] Rename recentProgresses to recentProgress
Michael Armbrust
2016-12-07
1
-1
/
+1
*
[SPARK-18588][TESTS] Fix flaky test: KafkaSourceStressForDontFailOnDataLossSuite
Shixiong Zhu
2016-12-07
4
-37
/
+90
*
[SPARK-18671][SS][TEST-MAVEN] Follow up PR to fix test for Maven
Tathagata Das
2016-12-06
2
-1
/
+3
*
[SPARK-18671][SS][TEST] Added tests to ensure stability of that all Structure...
Tathagata Das
2016-12-06
2
-1
/
+20
*
[SPARK-18695] Bump master branch version to 2.2.0-SNAPSHOT
Reynold Xin
2016-12-02
13
-13
/
+13
*
[SPARK-18516][SQL] Split state and progress in streaming
Tathagata Das
2016-11-29
1
-3
/
+4
*
[SPARK-3359][DOCS] Make javadoc8 working for unidoc/genjavadoc compatibility ...
hyukjinkwon
2016-11-29
5
-16
/
+28
*
[SPARK-18588][SS][KAFKA] Ignore the flaky kafka test
Shixiong Zhu
2016-11-28
1
-1
/
+1
*
[SPARK-18530][SS][KAFKA] Change Kafka timestamp column type to TimestampType
Shixiong Zhu
2016-11-22
2
-4
/
+93
*
[SPARK-18373][SPARK-18529][SS][KAFKA] Make failOnDataLoss=false work with Spa...
Shixiong Zhu
2016-11-22
5
-95
/
+523
*
[SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...
hyukjinkwon
2016-11-19
4
-38
/
+34
*
[SPARK-18400][STREAMING] NPE when resharding Kinesis Stream
Sean Owen
2016-11-16
1
-19
/
+23
*
[SPARK-17510][STREAMING][KAFKA] config max rate on a per-partition basis
cody koeninger
2016-11-14
5
-18
/
+131
*
[SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and e...
wm624@hotmail.com
2016-11-10
3
-0
/
+5
*
[SPARK-17829][SQL] Stable format for offset log
Tyson Condie
2016-11-09
4
-8
/
+82
*
[SPARK-18283][STRUCTURED STREAMING][KAFKA] Added test to check whether defaul...
Tathagata Das
2016-11-07
1
-0
/
+24
*
[SPARK-18212][SS][KAFKA] increase executor poll timeout
cody koeninger
2016-11-03
2
-2
/
+6
*
[SPARK-17813][SQL][KAFKA] Maximum data per trigger
cody koeninger
2016-10-27
2
-27
/
+151
*
[SPARK-17812][SQL][KAFKA] Assign and specific startingOffsets for structured ...
cody koeninger
2016-10-21
7
-45
/
+369
*
[SPARK-17999][KAFKA][SQL] Add getPreferredLocations for KafkaSourceRDD
jerryshao
2016-10-20
1
-0
/
+5
*
[SPARK-17841][STREAMING][KAFKA] drain commitQueue
cody koeninger
2016-10-18
1
-3
/
+3
*
[SPARK-17731][SQL][STREAMING] Metrics for structured streaming
Tathagata Das
2016-10-13
1
-0
/
+27
[next]