Commits

Breadcrumbs

History for

onaa1acfe

User selector

All users

Datepicker

All time

Commit History

Commits on Oct 9, 2019

• [SPARK-29392][CORE][SQL][STREAMING] Remove symbol literal syntax 'foo, deprecated in Scala 2.13, in favor of Symbol("foo")

  Show description for 2d871ad
  

  srowen

  authored and

  dongjoon-hyun

  committed
  2d871ad

  Copy full SHA for 2d871ad

Commits on Oct 3, 2019

• [SPARK-29054][SS] Invalidate Kafka consumer when new delegation token available

  Show description for 6b5e0e2
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  6b5e0e2

  Copy full SHA for 6b5e0e2

Commits on Oct 1, 2019

• [SPARK-29307][BUILD][TESTS] Remove scalatest deprecation warnings

  Show description for bd031c2
  dongjoon-hyun

  committed
  bd031c2

  Copy full SHA for bd031c2

• [SPARK-29300][TESTS] Compare catalyst and avro module benchmark in JDK8/11

  Show description for a0b3d7a
  dongjoon-hyun

  committed
  a0b3d7a

  Copy full SHA for a0b3d7a

Commits on Sep 30, 2019

• [SPARK-29291][CORE][SQL][STREAMING][MLLIB] Change procedure-like declaration to function + Unit for 2.13

  Show description for e1ea806
  

  srowen

  authored and

  dongjoon-hyun

  committed
  e1ea806

  Copy full SHA for e1ea806

Commits on Sep 26, 2019

• [SPARK-27748][SS][FOLLOWUP] Correct the order of logging token as debug log

  Show description for d3679a9
  

  HeartSaVioR

  authored and

  Marcelo Vanzin

  committed
  d3679a9

  Copy full SHA for d3679a9

• [SPARK-29197][SQL] Remove saveModeForDSV2 from DataFrameWriter

  Show description for c8159c7
  

  brkyvz

  authored and

  cloud-fan

  committed
  c8159c7

  Copy full SHA for c8159c7

Commits on Sep 24, 2019

• [SPARK-26848][SQL][SS] Introduce new option to Kafka source: offset by timestamp (starting/ending)

  Show description for 4513f1c
  

  HeartSaVioR

  authored and

  srowen

  committed
  4513f1c

  Copy full SHA for 4513f1c

Commits on Sep 19, 2019

• [SPARK-29141][SQL][TEST] Use SqlBasedBenchmark in SQL benchmarks

  Show description for a6a663c
  

  MaxGekk

  and

  dongjoon-hyun

  committed
  a6a663c

  Copy full SHA for a6a663c

Commits on Sep 18, 2019

• [SPARK-28683][BUILD] Upgrade Scala to 2.12.10

  Show description for 8c3f27c
  

  wangyum

  authored and

  dongjoon-hyun

  committed
  8c3f27c

  Copy full SHA for 8c3f27c

Commits on Sep 17, 2019

• [SPARK-29027][TESTS] KafkaDelegationTokenSuite fix when loopback canonical host name differs from localhost

  Show description for 71e7516
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  71e7516

  Copy full SHA for 71e7516

Commits on Sep 16, 2019

• [SPARK-23539][SS][FOLLOWUP][TESTS] Add UT to ensure existing query doesn't break with default conf of includeHeaders

  Show description for 88c8d5e
  

  HeartSaVioR

  authored and

  srowen

  committed
  88c8d5e

  Copy full SHA for 88c8d5e

Commits on Sep 13, 2019

• [SPARK-23539][SS] Add support for Kafka headers in Structured Streaming

  Show description for 1675d51
  

  2 peopleauthored and

  srowen

  committed
  1675d51

  Copy full SHA for 1675d51

Commits on Sep 12, 2019

• [SPARK-28998][SQL] reorganize the packages of DS v2 interfaces/classes

  Show description for 053dd85
  cloud-fan

  committed
  053dd85

  Copy full SHA for 053dd85

• [MINOR][DOCS] Fix few typos in the java docs

  Show description for 8f632d7
  

  dengziming

  authored and

  HyukjinKwon

  committed
  8f632d7

  Copy full SHA for 8f632d7

Commits on Sep 11, 2019

• [SPARK-29007][STREAMING][MLLIB][TESTS] Enforce not leaking SparkContext in tests which creates new StreamingContext with new SparkContext

  Show description for b62ef8f
  

  HeartSaVioR

  authored and

  Marcelo Vanzin

  committed
  b62ef8f

  Copy full SHA for b62ef8f

Commits on Sep 9, 2019

• [SPARK-28928][SS] Use Kafka delegation token protocol on sources/sinks

  Show description for e516f7e
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  e516f7e

  Copy full SHA for e516f7e

• [SPARK-28980][CORE][SQL][STREAMING][MLLIB] Remove most items deprecated in Spark 2.2.0 or earlier, for Spark 3

  Show description for 6378d4b
  

  srowen

  and

  HyukjinKwon

  committed
  6378d4b

  Copy full SHA for 6378d4b

• [SPARK-27420][DSTREAMS][KINESIS] KinesisInputDStream should expose a way to configure CloudWatch metrics

  Show description for 1f056eb
  

  sekikn

  authored and

  srowen

  committed
  1f056eb

  Copy full SHA for 1f056eb

Commits on Sep 4, 2019

• [SPARK-25151][SS] Apply Apache Commons Pool to KafkaDataConsumer

  Show description for 594c9c5
  

  HeartSaVioR

  authored and

  Marcelo Vanzin

  committed
  594c9c5

  Copy full SHA for 594c9c5

Commits on Sep 1, 2019

• [SPARK-28855][CORE][ML][SQL][STREAMING] Remove outdated usages of Experimental, Evolving annotations

  Show description for eb037a8
  srowen

  committed
  eb037a8

  Copy full SHA for eb037a8

Commits on Aug 30, 2019

• [SPARK-28922][SS] Safe Kafka parameter redaction

  Show description for d502c80
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  d502c80

  Copy full SHA for d502c80

Commits on Aug 29, 2019

• [SPARK-28760][SS][TESTS] Add Kafka delegation token end-to-end test with mini KDC

  Show description for 7d72c07
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  7d72c07

  Copy full SHA for 7d72c07

Commits on Aug 27, 2019

• [SPARK-28747][SQL] merge the two data source v2 fallback configs

  Show description for cb06209
  cloud-fan

  committed
  cb06209

  Copy full SHA for cb06209

• [MINOR][SS] Reuse KafkaSourceInitialOffsetWriter to deduplicate

  Show description for 64032cb
  

  HeartSaVioR

  authored and

  Marcelo Vanzin

  committed
  64032cb

  Copy full SHA for 64032cb

Commits on Aug 26, 2019

• [SPARK-28875][DSTREAMS][SS][TESTS] Add Task retry tests to make sure new consumer used

  Show description for b205269
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  b205269

  Copy full SHA for b205269

Commits on Aug 19, 2019

• [SPARK-28744][SQL][TEST] rename SharedSQLContext to SharedSparkSession

  Show description for 97dc4c0
  cloud-fan

  committed
  97dc4c0

  Copy full SHA for 97dc4c0

Commits on Aug 15, 2019

• [SPARK-28695][SS] Use CaseInsensitiveMap in KafkaSourceProvider to make source param handling more robust

  Show description for a493031
  

  gaborgsomogyi

  authored and

  cloud-fan

  committed
  a493031

  Copy full SHA for a493031

Commits on Aug 13, 2019

• [SPARK-28698][SQL] Support user-specified output schema in to_avro

  Show description for 48adc91
  

  gengliangwang

  authored and

  cloud-fan

  committed
  48adc91

  Copy full SHA for 48adc91

Commits on Aug 10, 2019

• [MINOR] Fix typos in comments and replace an explicit type with <>

  Show description for 8535df7
  

  younggyu chun

  authored and

  srowen

  committed
  8535df7

  Copy full SHA for 8535df7

Commits on Aug 9, 2019

• [SPARK-28163][SS] Use CaseInsensitiveMap for KafkaOffsetReader

  Show description for 5663386
  

  gaborgsomogyi

  authored and

  cloud-fan

  committed
  5663386

  Copy full SHA for 5663386

Commits on Jul 26, 2019

• [SPARK-28489][SS] Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets

  Show description for b9c2521
  

  zsxwing

  authored and

  dongjoon-hyun

  committed
  b9c2521

  Copy full SHA for b9c2521

Commits on Jul 23, 2019

• [SPARK-28469][SQL] Change CalendarIntervalType's readable string representation from calendarinterval to interval

  Show description for 022667c
  

  wangyum

  authored and

  dongjoon-hyun

  committed
  022667c

  Copy full SHA for 022667c

Commits on Jul 17, 2019

• [SPARK-28097][SQL] Map ByteType to SMALLINT for PostgresDialect

  Show description for eb5dc74
  

  mojodna

  authored and

  dongjoon-hyun

  committed
  eb5dc74

  Copy full SHA for eb5dc74

Commits on Jul 16, 2019

• [SPARK-28201][SQL][TEST][FOLLOWUP] Fix Integration test suite according to the new exception message

  Show description for 9a7f01d
  

  dongjoon-hyun

  authored and

  cloud-fan

  committed
  9a7f01d

  Copy full SHA for 9a7f01d

Pagination

Previous

Next