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
/
kafka-0-10-sql
/
src
/
main
Commit message (
Expand
)
Author
Age
Files
Lines
*
[SPARK-20156][CORE][SQL][STREAMING][MLLIB] Java String toLowerCase "Turkish l...
Sean Owen
2017-04-10
1
-10
/
+12
*
[SPARK-19721][SS] Good error message for version mismatch in log files
Liwei Lin
2017-03-16
1
-7
/
+7
*
[SPARK-19853][SS] uppercase kafka topics fail when startingOffsets are Specif...
uncleGen
2017-03-12
1
-34
/
+35
*
[SPARK-19886] Fix reportDataLoss if statement in SS KafkaSource
Burak Yavuz
2017-03-09
1
-13
/
+20
*
[SPARK-19719][SS] Kafka writer for both structured streaming and batch queires
Tyson Condie
2017-03-06
4
-5
/
+341
*
[SPARK-19517][SS] KafkaSource fails to initialize partition offsets
Roberto Agostino Vitillo
2017-02-17
1
-7
/
+25
*
[SPARK-19550][BUILD][CORE][WIP] Remove Java 7 support
Sean Owen
2017-02-16
1
-2
/
+1
*
[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
9
-429
/
+924
*
[SPARK-19227][SPARK-19251] remove unused imports and outdated comments
uncleGen
2017-01-18
1
-1
/
+1
*
[MINOR][DOCS] Remove consecutive duplicated words/typo in Spark Repo
Niranjan Padmanabhan
2017-01-04
1
-1
/
+1
*
[SPARK-18588][SS][KAFKA] Create a new KafkaConsumer when error happens to fix...
Shixiong Zhu
2016-12-21
2
-30
/
+49
*
[SPARK-18588][TESTS] Fix flaky test: KafkaSourceStressForDontFailOnDataLossSuite
Shixiong Zhu
2016-12-07
2
-8
/
+33
*
[SPARK-18671][SS][TEST] Added tests to ensure stability of that all Structure...
Tathagata Das
2016-12-06
1
-1
/
+8
*
[SPARK-18530][SS][KAFKA] Change Kafka timestamp column type to TimestampType
Shixiong Zhu
2016-11-22
1
-3
/
+13
*
[SPARK-18373][SPARK-18529][SS][KAFKA] Make failOnDataLoss=false work with Spa...
Shixiong Zhu
2016-11-22
3
-48
/
+253
*
[SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...
hyukjinkwon
2016-11-19
1
-1
/
+1
*
[SPARK-17829][SQL] Stable format for offset log
Tyson Condie
2016-11-09
3
-7
/
+28
*
[SPARK-18212][SS][KAFKA] increase executor poll timeout
cody koeninger
2016-11-03
1
-1
/
+4
*
[SPARK-17813][SQL][KAFKA] Maximum data per trigger
cody koeninger
2016-10-27
1
-25
/
+82
*
[SPARK-17812][SQL][KAFKA] Assign and specific startingOffsets for structured ...
cody koeninger
2016-10-21
4
-33
/
+208
*
[SPARK-17999][KAFKA][SQL] Add getPreferredLocations for KafkaSourceRDD
jerryshao
2016-10-20
1
-0
/
+5
*
[SPARK-17834][SQL] Fetch the earliest offsets manually in KafkaSource instead...
Shixiong Zhu
2016-10-13
2
-26
/
+48
*
[SPARK-17346][SQL] Add Kafka source for Structured Streaming
Shixiong Zhu
2016-10-05
7
-0
/
+1057