Commits

Branch selector

 master

User selector

zsxwing

Datepicker

All time

Commit History

Commits on Dec 10, 2019

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

  Show description for cfd7ca9
  zsxwing

  committed
  cfd7ca9

Commits on Sep 5, 2019

• [SPARK-28976][CORE] Use KeyLock to simplify MapOutputTracker.getStatuses

  Show description for 84a4d3a
  zsxwing

  committed
  84a4d3a

Commits on Sep 3, 2019

• [SPARK-3137][CORE] Replace the global TorrentBroadcast lock with fine grained KeyLock

  Show description for 8980093
  zsxwing

  committed
  8980093

Commits on Aug 9, 2019

• [SPARK-28651][SS] Force the schema of Streaming file source to be nullable

  Show description for 5bb6994
  

  zsxwing

  authored and

  HyukjinKwon

  committed
  5bb6994

Commits on Jul 30, 2019

• [SPARK-28556][SQL] QueryExecutionListener should also notify Error

  Show description for 196a4d7
  

  zsxwing

  authored and

  HyukjinKwon

  committed
  196a4d7

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

Commits on Jul 22, 2019

• [SPARK-28456][SQL] Add a public API Encoder.makeCopy to allow creating Encoder without touching Scala Reflection

  Show description for 62e2824
  

  zsxwing

  authored and

  cloud-fan

  committed
  62e2824

Commits on May 28, 2019

• [SPARK-20547][REPL] Throw RemoteClassLoadedError for transient errors in ExecutorClassLoader

  Show description for 04f142d
  zsxwing

  committed
  04f142d

Commits on May 16, 2019

• [SPARK-27735][SS] Parsing interval string should be case-insensitive in SS

  Show description for 6a317c8
  

  zsxwing

  authored and

  dongjoon-hyun

  committed
  6a317c8

Commits on Apr 22, 2019

• [SPARK-27496][CORE] Fatal errors should also be sent back to the sender

  Show description for 009059e
  

  zsxwing

  authored and

  dongjoon-hyun

  committed
  009059e

Commits on Apr 9, 2019

• [SPARK-27394][WEBUI] Flush LiveEntity if necessary when receiving SparkListenerExecutorMetricsUpdate

  Show description for 5ff39cd
  

  zsxwing

  authored and

  Marcelo Vanzin

  committed
  5ff39cd

Commits on Mar 26, 2019

• [SPARK-27275][CORE] Fix potential corruption in EncryptedMessage.transferTo

  Show description for 5624bfb
  

  zsxwing

  authored and

  cloud-fan

  committed
  5624bfb

Commits on Mar 21, 2019

• [SPARK-27221][SQL] Improve the assert error message in TreeNode.parseToJson

  Show description for c26379b
  

  zsxwing

  authored and

  HyukjinKwon

  committed
  c26379b

Commits on Mar 9, 2019

• [SPARK-27111][SS] Fix a race that a continuous query may fail with InterruptedException

  Show description for 6e1c082
  zsxwing

  committed
  6e1c082

Commits on Feb 20, 2019

• [SPARK-26824][SS] Fix the checkpoint location and _spark_metadata when it contains special chars

  Show description for 77b99af
  zsxwing

  committed
  77b99af

Commits on Feb 1, 2019

• [SPARK-26806][SS] EventTimeStats.merge should handle zeros correctly

  Show description for 03a928c
  zsxwing

  committed
  03a928c

Commits on Jan 22, 2019

• [SPARK-26665][CORE] Fix a bug that BlockTransferService.fetchBlockSync may hang forever

  Show description for 66450bb
  zsxwing

  committed
  66450bb

Commits on Jan 14, 2019

• [SPARK-26350][SS] Allow to override group id of the Kafka consumer

  Show description for bafc7ac
  zsxwing

  committed
  bafc7ac

Commits on Dec 21, 2018

• [SPARK-26267][SS] Retry when detecting incorrect offsets from Kafka

  Show description for 8e76d66
  zsxwing

  committed
  8e76d66

Commits on Nov 23, 2018

• [SPARK-26069][TESTS][FOLLOWUP] Add another possible error message

  Show description for 92fc0a8
  

  zsxwing

  authored and

  srowen

  committed
  92fc0a8

Commits on Nov 21, 2018

• [SPARK-26120][TESTS][SS][SPARKR] Fix a streaming query leak in Structured Streaming R tests

  Show description for 4b7f7ef
  

  zsxwing

  authored and

  HyukjinKwon

  committed
  4b7f7ef

Commits on Nov 16, 2018

• [SPARK-26092][SS] Use CheckpointFileManager to write the streaming metadata file

  Show description for 058c460
  zsxwing

  committed
  058c460

• [SPARK-26069][TESTS] Fix flaky test: RpcIntegrationSuite.sendRpcWithStreamFailures

  Show description for 99cbc51
  zsxwing

  committed
  99cbc51

Commits on Nov 14, 2018

• [SPARK-26042][SS][TESTS] Fix a potential hang in KafkaContinuousSourceTopicDeletionSuite

  Show description for 4035c98
  zsxwing

  committed
  4035c98

Commits on Oct 31, 2018

• [SPARK-25899][TESTS] Fix flaky CoarseGrainedSchedulerBackendSuite

  Show description for 6be3cce
  

  zsxwing

  authored and

  gatorsmile

  committed
  6be3cce

Commits on Oct 30, 2018

• [SPARK-25773][CORE] Cancel zombie tasks in a result stage when the job finishes

  Show description for c36537f
  zsxwing

  committed
  c36537f

Commits on Oct 26, 2018

• [SPARK-25822][PYSPARK] Fix a race condition when releasing a Python worker

  Show description for 86d469a
  

  zsxwing

  authored and

  ueshin

  committed
  86d469a

Commits on Oct 22, 2018

• [SPARK-25771][PYSPARK] Fix improper synchronization in PythonWorkerFactory

  Show description for bd66c73
  zsxwing

  committed
  bd66c73

Commits on Oct 5, 2018

• [SPARK-25644][SS] Fix java foreachBatch in DataStreamWriter

  Show description for 7dcc90f
  zsxwing

  committed
  7dcc90f

Commits on Sep 30, 2018

• [SPARK-25568][CORE] Continue to update the remaining accumulators when failing to update one accumulator

  Show description for b6b8a66
  

  zsxwing

  authored and

  gatorsmile

  committed
  b6b8a66

Commits on Sep 25, 2018

• [SPARK-25495][SS] FetchedData.reset should reset all fields

  Show description for 66d2987
  zsxwing

  committed
  66d2987

Commits on Sep 5, 2018

• [SPARK-25336][SS]Revert SPARK-24863 and SPARK-24748

  Show description for 2119e51
  

  zsxwing

  authored and

  cloud-fan

  committed
  2119e51

Commits on Aug 31, 2018

• [SPARK-25288][TESTS] Fix flaky Kafka transaction tests

  Show description for aa70a0a
  zsxwing

  committed
  aa70a0a

Commits on Aug 28, 2018

• [SPARK-25005][SS] Support non-consecutive offsets for Kafka

  Show description for 1149c4e
  zsxwing

  committed
  1149c4e

• [SPARK-25218][CORE] Fix potential resource leaks in TransportServer and SocketAuthHelper

  Show description for 592e3a4
  zsxwing

  committed
  592e3a4

Pagination

PreviousNext