Commits

Branch selector

 master

User selector

gaborgsomogyi

Datepicker

All time

Commit History

Commits on Nov 9, 2019

• [MINOR] FsHistoryProvider import cleanup

  Show description for 12598e1
  

  gaborgsomogyi

  authored and

  srowen

  committed
  12598e1

  Copy full SHA for 12598e1

Commits on Nov 8, 2019

• [SPARK-21869][SS] Apply Apache Commons Pool to Kafka producer

  Show description for 3641c3d
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  3641c3d

  Copy full SHA for 3641c3d

Commits on Oct 29, 2019

• [SPARK-29637][CORE] Add description to Job SHS web API

  Show description for 9c817a8
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  9c817a8

  Copy full SHA for 9c817a8

Commits on Oct 25, 2019

• [SPARK-29580][TESTS] Add kerberos debug messages for Kafka secure tests

  Show description for 2549391
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  2549391

  Copy full SHA for 2549391

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 Sep 24, 2019

• [SPARK-29082][CORE] Skip delegation token generation if no credentials are available

  Show description for d75588c
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  d75588c

  Copy full SHA for d75588c

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 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

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 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 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 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 16, 2019

• [SPARK-27485][FOLLOWUP] Do not reduce the number of partitions for repartition in adaptive execution - fix compilation

  Show description for 113f62d
  

  gaborgsomogyi

  authored and

  hvanhovell

  committed
  113f62d

  Copy full SHA for 113f62d

Commits on Jul 15, 2019

• [SPARK-28404][SS] Fix negative timeout value in RateStreamContinuousPartitionReader

  Show description for 8f7ccc5
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  8f7ccc5

  Copy full SHA for 8f7ccc5

Commits on Jul 11, 2019

• [SPARK-23472][CORE] Add defaultJavaOptions for driver and executor.

  Show description for f830005
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  f830005

  Copy full SHA for f830005

• [SPARK-28055][SS][DSTREAMS] Add delegation token custom AdminClient configurations.

  Show description for d47c219
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  d47c219

  Copy full SHA for d47c219

Commits on Jul 10, 2019

• [SPARK-28335][DSTREAMS][TEST] DirectKafkaStreamSuite wait for Kafka async commit

  Show description for 579edf4
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  579edf4

  Copy full SHA for 579edf4

Commits on Jul 8, 2019

• [SPARK-28261][CORE] Fix client reuse test

  Show description for e11a558
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  e11a558

  Copy full SHA for e11a558

Commits on Jul 3, 2019

• [MINOR] Add requestHeaderSize debug log

  Show description for 0b6c2c2
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  0b6c2c2

  Copy full SHA for 0b6c2c2

Commits on Jul 2, 2019

• [SPARK-28232][SS][SQL] Add groupIdPrefix for Kafka batch connector

  Show description for a006c85
  

  gaborgsomogyi

  authored and

  cloud-fan

  committed
  a006c85

  Copy full SHA for a006c85

• [SPARK-23098][SQL] Migrate Kafka Batch source to v2.

  Show description for 0a4f985
  

  gaborgsomogyi

  authored and

  cloud-fan

  committed
  0a4f985

  Copy full SHA for 0a4f985

Commits on Jun 26, 2019

• [SPARK-28005][YARN] Remove unnecessary log from SparkRackResolver

  Show description for 8313015
  

  gaborgsomogyi

  authored and

  squito

  committed
  8313015

  Copy full SHA for 8313015

Commits on Jun 24, 2019

• [MINOR][SQL][DOCS] failOnDataLoss has effect on batch queries so fix the doc

  Show description for 1a915bf
  

  gaborgsomogyi

  authored and

  srowen

  committed
  1a915bf

  Copy full SHA for 1a915bf

Commits on Jun 3, 2019

• [SPARK-27748][SS] Kafka consumer/producer password/token redaction.

  Show description for 911fadf
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  911fadf

  Copy full SHA for 911fadf

Commits on May 24, 2019

• [MINOR][DOC] ForeachBatch doc fix.

  Show description for 4e7908f
  

  gaborgsomogyi

  authored and

  HyukjinKwon

  committed
  4e7908f

  Copy full SHA for 4e7908f

Commits on May 15, 2019

• [SPARK-27687][SS] Rename Kafka consumer cache capacity conf and document caching

  Show description for efa3035
  

  gaborgsomogyi

  authored and

  dongjoon-hyun

  committed
  efa3035

  Copy full SHA for efa3035

Commits on May 7, 2019

• [SPARK-27294][SS] Add multi-cluster Kafka delegation token

  Show description for 2f55809
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  2f55809

  Copy full SHA for 2f55809

Commits on Apr 29, 2019

• [SPARK-23014][SS] Fully remove V1 memory sink.

  Show description for fb6b19a
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  fb6b19a

  Copy full SHA for fb6b19a

Commits on Apr 11, 2019

• [SPARK-27270][SS] Add Kafka dynamic JAAS authentication debug possibility

  Show description for 94adffa
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  94adffa

  Copy full SHA for 94adffa

Commits on Apr 2, 2019

• [MINOR][DSTREAMS] Add DStreamCheckpointData.cleanup warning if delete returns false

  Show description for 3628242
  

  gaborgsomogyi

  authored and

  srowen

  committed
  3628242

  Copy full SHA for 3628242

• [SPARK-26998][CORE] Remove SSL configuration from executors

  Show description for 57aff93
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  57aff93

  Copy full SHA for 57aff93

Commits on Mar 11, 2019

• [SPARK-26856][PYSPARK] Python support for from_avro and to_avro APIs

  Show description for 3729efb
  

  gaborgsomogyi

  authored and

  HyukjinKwon

  committed
  3729efb

  Copy full SHA for 3729efb

• [SPARK-24621][WEBUI] Show secure URLs on web pages

  Show description for 29d9021
  

  gaborgsomogyi

  authored and

  srowen

  committed
  29d9021

  Copy full SHA for 29d9021

Commits on Mar 7, 2019

• [SPARK-27022][DSTREAMS] Add kafka delegation token support.

  Show description for 98a8725
  

  gaborgsomogyi

  authored and

  Marcelo Vanzin

  committed
  98a8725

  Copy full SHA for 98a8725

Pagination

Previous

Next