Commits

Branch selector

 master

User selector

koeninger

Datepicker

All time

Commit History

Commits on Jan 23, 2020

• [SPARK-30570][BUILD] Update scalafmt plugin to 1.0.3 with onlyChangedFiles feature

  Show description for 843224e
  

  koeninger

  authored and

  dongjoon-hyun

  committed
  843224e

Commits on Dec 3, 2018

• [SPARK-26177] Config change followup to [] Automated formatting for Scala code

  Show description for 5e5b9f2
  

  koeninger

  authored and

  srowen

  committed
  5e5b9f2

Commits on Nov 29, 2018

• [SPARK-26177] Automated formatting for Scala code

  Show description for 9a09e91
  

  koeninger

  authored and

  srowen

  committed
  9a09e91

Commits on Feb 27, 2018

• [SPARK-17147][STREAMING][KAFKA] Allow non-consecutive offsets

  Show description for eac0b06
  

  koeninger

  authored and

  srowen

  committed
  eac0b06

Commits on Apr 19, 2017

• [SPARK-20036][DOC] Note incompatible dependencies on org.apache.kafka artifacts

  Show description for 71a8e9d
  

  koeninger

  authored and

  srowen

  committed
  71a8e9d

Commits on Nov 14, 2016

• [SPARK-17510][STREAMING][KAFKA] config max rate on a per-partition basis

  Show description for 89d1fa5
  

  koeninger

  authored and

  zsxwing

  committed
  89d1fa5

Commits on Nov 3, 2016

• [SPARK-18212][SS][KAFKA] increase executor poll timeout

  Show description for 67659c9
  

  koeninger

  authored and

  marmbrus

  committed
  67659c9

Commits on Oct 27, 2016

• [SPARK-17813][SQL][KAFKA] Maximum data per trigger

  Show description for 1042325
  

  koeninger

  authored and

  zsxwing

  committed
  1042325

Commits on Oct 21, 2016

• [STREAMING][KAFKA][DOC] clarify kafka settings needed for larger batches

  Show description for c9720b2
  

  koeninger

  authored and

  zsxwing

  committed
  c9720b2

• [SPARK-17812][SQL][KAFKA] Assign and specific startingOffsets for structured stream

  Show description for 268ccb9
  

  koeninger

  authored and

  zsxwing

  committed
  268ccb9

Commits on Oct 18, 2016

• [SPARK-17841][STREAMING][KAFKA] drain commitQueue

  Show description for cd106b0
  

  koeninger

  authored and

  rxin

  committed
  cd106b0

Commits on Oct 12, 2016

• [SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll twice

  Show description for f9a56a1
  

  koeninger

  authored and

  zsxwing

  committed
  f9a56a1

• [SPARK-17853][STREAMING][KAFKA][DOC] make it clear that reusing group.id is bad

  Show description for c264ef9
  

  koeninger

  authored and

  rxin

  committed
  c264ef9

Commits on Aug 5, 2016

• [SPARK-16312][STREAMING][KAFKA][DOC] Doc for Kafka 0.10 integration

  Show description for c9f2501
  

  koeninger

  authored and

  srowen

  committed
  c9f2501

Commits on Jul 9, 2016

• [SPARK-13569][STREAMING][KAFKA] pattern based topic subscription

  Show description for fd6e8f0
  

  koeninger

  authored and

  tdas

  committed
  fd6e8f0

Commits on Jul 6, 2016

• [SPARK-16212][STREAMING][KAFKA] apply test tweaks from 0-10 to 0-8 as well

  Show description for b8ebf63
  

  koeninger

  authored and

  tdas

  committed
  b8ebf63

Commits on Jul 5, 2016

• [SPARK-16359][STREAMING][KAFKA] unidoc skip kafka 0.10

  Show description for 1f0d021
  

  koeninger

  authored and

  tdas

  committed
  1f0d021

• [SPARK-16212][STREAMING][KAFKA] use random port for embedded kafka

  Show description for 1fca9da
  

  koeninger

  authored and

  tdas

  committed
  1fca9da

Commits on Jul 1, 2016

• [SPARK-12177][STREAMING][KAFKA] limit api surface area

  Show description for fbfd0ab
  

  koeninger

  authored and

  tdas

  committed
  fbfd0ab

Commits on Jun 30, 2016

• [SPARK-16212][STREAMING][KAFKA] code cleanup from review feedback

  Show description for c622633
  

  koeninger

  authored and

  tdas

  committed
  c622633

• [SPARK-12177][STREAMING][KAFKA] Update KafkaDStreams to new Kafka 0.10 Consumer API

  Show description for dedbcee
  

  koeninger

  authored and

  tdas

  committed
  dedbcee

Commits on May 11, 2016

• [SPARK-15085][STREAMING][KAFKA] Rename streaming-kafka artifact

  Show description for 89e67d6
  

  koeninger

  authored and

  rxin

  committed
  89e67d6

Commits on Feb 7, 2016

• [SPARK-10963][STREAMING][KAFKA] make KafkaCluster public

  Show description for 140ddef
  

  koeninger

  authored and

  srowen

  committed
  140ddef

Commits on Dec 8, 2015

• [SPARK-12103][STREAMING][KAFKA][DOC] document that K means Key and V …

  Show description for 48a9804
  

  koeninger

  authored and

  srowen

  committed
  48a9804

Commits on Aug 25, 2015

• [SPARK-9786] [STREAMING] [KAFKA] fix backpressure so it works with defa…

  Show description for d9c25de
  

  koeninger

  authored and

  tdas

  committed
  d9c25de

Commits on Aug 13, 2015

• [SPARK-9780] [STREAMING] [KAFKA] prevent NPE if KafkaRDD instantiation …

  Show description for 8ce6096
  

  koeninger

  authored and

  tdas

  committed
  8ce6096

Commits on Aug 6, 2015

• [DOCS] [STREAMING] make the existing parameter docs for OffsetRange ac…

  Show description for 1723e34
  

  koeninger

  authored and

  tdas

  committed
  1723e34

Commits on Jul 31, 2015

• [SPARK-9472] [STREAMING] consistent hadoop configuration, streaming only

  Show description for 9307f56
  

  koeninger

  authored and

  tdas

  committed
  9307f56

Commits on Jun 20, 2015

• [SPARK-8127] [STREAMING] [KAFKA] KafkaRDD optimize count() take() isEmpty()

  Show description for 1b6fe9b
  

  koeninger

  authored and

  tdas

  committed
  1b6fe9b

• [SPARK-8390] [STREAMING] [KAFKA] fix docs related to HasOffsetRanges

  Show description for b305e37
  

  koeninger

  authored and

  tdas

  committed
  b305e37

Commits on Jun 19, 2015

• [SPARK-8389] [STREAMING] [KAFKA] Example of getting offset ranges out o…

  Show description for 47af7c1
  

  koeninger

  authored and

  srowen

  committed
  47af7c1

Commits on Jun 7, 2015

• [SPARK-2808] [STREAMING] [KAFKA] cleanup tests from

  Show description for b127ff8
  

  koeninger

  authored and

  srowen

  committed
  b127ff8

Commits on May 2, 2015

• [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2

  Show description for 4786484
  

  koeninger

  authored and

  tdas

  committed
  4786484

Commits on Apr 12, 2015

• [SPARK-6431][Streaming][Kafka] Error message for partition metadata requ...

  Show description for 6ac8eea
  

  koeninger

  authored and

  srowen

  committed
  6ac8eea

Commits on Feb 11, 2015

• [SPARK-4964] [Streaming] refactor createRDD to take leaders via map instead of array

  Show description for 658687b
  

  koeninger

  authored and

  tdas

  committed
  658687b

Pagination

Previous

Next