Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Nov 30, 2016

• [SPARK-18516][SQL] Split state and progress in streaming

  Show description for c3d08e2
  

  tdas

  authored and

  marmbrus

  committed
  c3d08e2

Commits on Nov 29, 2016

• [SPARK-3359][DOCS] Make javadoc8 working for unidoc/genjavadoc compatibility in Java API documentation

  Show description for f830bb9
  

  HyukjinKwon

  authored and

  srowen

  committed
  f830bb9

• [SPARK-18588][SS][KAFKA] Ignore the flaky kafka test

  Show description for 1633ff3
  zsxwing

  committed
  1633ff3

Commits on Nov 23, 2016

• [SPARK-18530][SS][KAFKA] Change Kafka timestamp column type to TimestampType

  Show description for d0212eb
  zsxwing

  committed
  d0212eb

Commits on Nov 22, 2016

• [SPARK-18373][SPARK-18529][SS][KAFKA] Make failOnDataLoss=false work with Spark jobs

  Show description for 2fd101b
  

  zsxwing

  authored and

  tdas

  committed
  2fd101b

Commits on Nov 19, 2016

• [SPARK-18445][BUILD][DOCS] Fix the markdown for Note:/NOTE:/Note that/'''Note:''' across Scala/Java API documentation

  Show description for d5b1d5f
  

  HyukjinKwon

  authored and

  srowen

  committed
  d5b1d5f

Commits on Nov 16, 2016

• [SPARK-18400][STREAMING] NPE when resharding Kinesis Stream

  Show description for 43a2689
  srowen

  committed
  43a2689

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 10, 2016

• [SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and example

  Show description for 22a9d06
  

  wangmiao1981

  authored and

  srowen

  committed
  22a9d06

Commits on Nov 9, 2016

• [SPARK-17829][SQL] Stable format for offset log

  Show description for 3f62e1b
  

  tcondie

  authored and

  zsxwing

  committed
  3f62e1b

Commits on Nov 7, 2016

• [SPARK-18283][STRUCTURED STREAMING][KAFKA] Added test to check whether default starting offset in latest

  Show description for b06c23d
  

  tdas

  authored and

  zsxwing

  committed
  b06c23d

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

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

  Show description for 268ccb9
  

  koeninger

  authored and

  zsxwing

  committed
  268ccb9

Commits on Oct 20, 2016

• [SPARK-17999][KAFKA][SQL] Add getPreferredLocations for KafkaSourceRDD

  Show description for 947f4f2
  

  jerryshao

  authored and

  zsxwing

  committed
  947f4f2

Commits on Oct 18, 2016

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

  Show description for cd106b0
  

  koeninger

  authored and

  rxin

  committed
  cd106b0

Commits on Oct 13, 2016

• [SPARK-17731][SQL][STREAMING] Metrics for structured streaming

  Show description for 7106866
  tdas

  committed
  7106866

• [SPARK-17834][SQL] Fetch the earliest offsets manually in KafkaSource instead of counting on KafkaConsumer

  Show description for 08eac35
  zsxwing

  committed
  08eac35

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

Commits on Oct 11, 2016

• [SPARK-17346][SQL][TESTS] Fix the flaky topic deletion in KafkaSourceStressSuite

  Show description for 75b9e35
  

  zsxwing

  authored and

  tdas

  committed
  75b9e35

Commits on Oct 6, 2016

• [SPARK-17803][TESTS] Upgrade docker-client dependency

  Show description for 49d11d4
  

  ckadner

  authored and

  JoshRosen

  committed
  49d11d4

• [SPARK-17346][SQL][TEST-MAVEN] Generate the sql test jar to fix the maven build

  Show description for b678e46
  

  zsxwing

  authored and

  tdas

  committed
  b678e46

Commits on Oct 5, 2016

• [SPARK-17346][SQL] Add Kafka source for Structured Streaming

  Show description for 9293734
  

  zsxwing

  authored and

  tdas

  committed
  9293734

Commits on Sep 21, 2016

• [SPARK-17418] Prevent kinesis-asl-assembly artifacts from being published

  Show description for d7ee122
  JoshRosen

  committed
  d7ee122

Commits on Sep 19, 2016

• [SPARK-17473][SQL] fixing docker integration tests error due to different versions of jars.

  Show description for cdea1d1
  

  sureshthalamati

  authored and

  JoshRosen

  committed
  cdea1d1

Commits on Sep 16, 2016

• [SPARK-17534][TESTS] Increase timeouts for DirectKafkaStreamSuite tests

  Show description for fc1efb7
  

  a-roberts

  authored and

  srowen

  committed
  fc1efb7

Commits on Sep 7, 2016

• [SPARK-17359][SQL][MLLIB] Use ArrayBuffer.+=(A) instead of ArrayBuffer.append(A) in performance critical paths

  Show description for 3ce3a28
  

  lw-lin

  authored and

  srowen

  committed
  3ce3a28

Commits on Aug 25, 2016

• [SPARK-17229][SQL] PostgresDialect shouldn't widen float and short types during reads

  Show description for a133057
  

  JoshRosen

  authored and

  hvanhovell

  committed
  a133057

Commits on Aug 13, 2016

• [SPARK-17023][BUILD] Upgrade to Kafka 0.10.0.1 release

  Show description for 67f025d
  

  lresende

  authored and

  srowen

  committed
  67f025d

Commits on Aug 9, 2016

• [SPARK-16950] [PYSPARK] fromOffsets parameter support in KafkaUtils.createDirectStream for python3

  Show description for 29081b5
  

  Mariusz Strzelecki

  authored and

  davies

  committed
  29081b5

Commits on Aug 8, 2016

• [SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add much and remove whitelisting

  Show description for 9216901
  

  holdenk

  authored and

  Marcelo Vanzin

  committed
  9216901

Commits on Aug 5, 2016

• [SPARK-13238][CORE] Add ganglia dmax parameter

  Show description for 1f96c97
  

  ekasitk

  authored and

  Marcelo Vanzin

  committed
  1f96c97

• [SPARK-16625][SQL] General data types to be mapped to Oracle

  Show description for 39a2b2e
  

  wangyum

  authored and

  srowen

  committed
  39a2b2e

Commits on Aug 1, 2016

• [SPARK-16776][STREAMING] Replace deprecated API in KafkaTestUtils for 0.10.0.

  Show description for f93ad4f
  

  HyukjinKwon

  authored and

  srowen

  committed
  f93ad4f

Commits on Jul 26, 2016

• [TEST][STREAMING] Fix flaky Kafka rate controlling test

  Show description for 03c2743
  tdas

  committed
  03c2743

Pagination

PreviousNext