8000 Commits · linbaicome/spark · GitHub

More Web Proxy on the site http://driver.im/

Commits

Commits on Aug 9, 2019

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

zsxwing
authored and
HyukjinKwon
committed

Commits on Jul 30, 2019

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

zsxwing
authored and
HyukjinKwon
committed

Commits on Jul 26, 2019

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

zsxwing
authored and
dongjoon-hyun
committed

Commits on Jul 22, 2019

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

zsxwing
authored and
cloud-fan
committed

Commits on May 28, 2019

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

Commits on May 16, 2019

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

zsxwing
authored and
dongjoon-hyun
committed

Commits on Apr 22, 2019

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

zsxwing
authored and
dongjoon-hyun
committed

Commits on Apr 9, 2019

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

zsxwing
authored and
Marcelo Vanzin
committed

Commits on Mar 26, 2019

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

zsxwing
authored and
cloud-fan
committed

Commits on Mar 21, 2019

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

zsxwing
authored and
HyukjinKwon
committed

Commits on Mar 9, 2019

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

Commits on Feb 20, 2019

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

Commits on Feb 1, 2019

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

Commits on Jan 22, 2019

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

Commits on Jan 14, 2019

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

Commits on Dec 21, 2018

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

Commits on Nov 23, 2018

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

zsxwing
authored and
srowen
committed

Commits on Nov 21, 2018

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

zsxwing
authored and
HyukjinKwon
committed

Commits on Nov 16, 2018

Commits on Nov 14, 2018

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

Commits on Oct 31, 2018

[SPARK-25899][TESTS] Fix flaky CoarseGrainedSchedulerBackendSuite

zsxwing
authored and
gatorsmile
committed

Commits on Oct 30, 2018

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

Commits on Oct 26, 2018

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

zsxwing
authored and
ueshin
committed

Commits on Oct 22, 2018

[SPARK-25771][PYSPARK] Fix improper synchronization in PythonWorkerFactory
zsxwing
committed

Commits on Oct 5, 2018

[SPARK-25644][SS] Fix java foreachBatch in DataStreamWriter
zsxwing
committed

Commits on Sep 30, 2018

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

zsxwing
authored and
gatorsmile
committed

Commits on Sep 25, 2018

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

Commits on Sep 5, 2018

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

zsxwing
authored and
cloud-fan
committed

Commits on Aug 31, 2018

[SPARK-25288][TESTS] Fix flaky Kafka transaction tests
zsxwing
committed

Commits on Aug 28, 2018

Commits on Aug 25, 2018

[SPARK-25214][SS][FOLLOWUP] Fix the issue that Kafka v2 source may return duplicated records when `failOnDataLoss=false`
zsxwing
committed

Commits on Aug 24, 2018

[SPARK-25214][SS] Fix the issue that Kafka v2 source may return duplicated records when `failOnDataLoss=false`
zsxwing
committed

Commits on Aug 17, 2018

[SPARK-25116][TESTS] Fix the Kafka cluster leak and clean up cached producers
zsxwing
committed

0