Commits

Branch selector

 master

User selector

zsxwing

Datepicker

All time

Commit History

Commits on Jul 14, 2017

• [SPARK-21421][SS] Add the query id as a local property to allow source and sink using it

  Show description for 2d968a0
  zsxwing

  committed
  2d968a0

Commits on Jul 11, 2017

• [SPARK-21369][CORE] Don't use Scala Tuple2 in common/network-*

  Show description for 833eab2
  

  zsxwing

  authored and

  cloud-fan

  committed
  833eab2

Commits on Jul 6, 2017

• [SPARK-21248][SS] The clean up codes in StreamExecution should not be interrupted

  Show description for ab866f1
  zsxwing

  committed
  ab866f1

Commits on Jun 30, 2017

• [SPARK-21253][CORE][HOTFIX] Fix Scala 2.10 build

  Show description for cfc696f
  zsxwing

  committed
  cfc696f

• [SPARK-21253][CORE] Disable spark.reducer.maxReqSizeShuffleToMem

  Show description for 80f7ac3
  

  zsxwing

  authored and

  cloud-fan

  committed
  80f7ac3

• [SPARK-21253][CORE] Fix a bug that StreamCallback may not be notified if network errors happen

  Show description for 4996c53
  

  zsxwing

  authored and

  cloud-fan

  committed
  4996c53

Commits on Jun 22, 2017

• [SPARK-21167][SS] Decode the path generated by File sink to handle special characters

  Show description for d66b143
  zsxwing

  committed
  d66b143

Commits on Jun 12, 2017

• [SPARK-20979][SS] Add RateSource to generate values for tests and benchmark

  Show description for 74a432d
  zsxwing

  committed
  74a432d

Commits on Jun 5, 2017

• [SPARK-20957][SS][TESTS] Fix o.a.s.sql.streaming.StreamingQueryManagerSuite listing

  Show description for bc537e4
  

  zsxwing

  authored and

  tdas

  committed
  bc537e4

Commits on Jun 2, 2017

• [SPARK-20955][CORE] Intern "executorId" to reduce the memory usage

  Show description for 16186cd
  zsxwing

  committed
  16186cd

Commits on Jun 1, 2017

• [SPARK-20940][CORE] Replace IllegalAccessError with IllegalStateException

  Show description for 24db358
  zsxwing

  committed
  24db358

• [SPARK-20894][SS] Resolve the checkpoint location in driver and use the resolved path in state store

  Show description for 2bc3272
  zsxwing

  committed
  2bc3272

Commits on May 27, 2017

• [SPARK-20843][CORE] Add a config to set driver terminate timeout

  Show description for 6c1dbd6
  zsxwing

  committed
  6c1dbd6

Commits on May 25, 2017

• [SPARK-20874][EXAMPLES] Add Structured Streaming Kafka Source to examples project

  Show description for 98c3852
  zsxwing

  committed
  98c3852

Commits on May 18, 2017

• [SPARK-13747][CORE] Add ThreadUtils.awaitReady and disallow Await.ready

  Show description for 324a904
  zsxwing

  committed
  324a904

Commits on May 17, 2017

• [SPARK-20788][CORE] Fix the Executor task reaper's false alarm warning logs

  Show description for f8e0f0f
  zsxwing

  committed
  f8e0f0f

Commits on May 16, 2017

• [SPARK-20529][CORE] Allow worker and master work with a proxy server

  Show description for 9150bca
  zsxwing

  committed
  9150bca

Commits on May 12, 2017

• [SPARK-20702][CORE] TaskContextImpl.markTaskCompleted should not hide the original error

  Show description for 7d6ff39
  zsxwing

  committed
  7d6ff39

Commits on May 5, 2017

• [SPARK-20603][SS][TEST] Set default number of topic partitions to 1 to reduce the load

  Show description for bd57882
  zsxwing

  committed
  bd57882

Commits on Apr 27, 2017

• [SPARK-20452][SS][KAFKA] Fix a potential ConcurrentModificationException for batch Kafka DataFrame

  Show description for 823baca
  

  zsxwing

  authored and

  tdas

  committed
  823baca

• [SPARK-20461][CORE][SS] Use UninterruptibleThread for Executor and fix the potential hang in CachedKafkaConsumer

  Show description for 01c999e
  

  zsxwing

  authored and

  tdas

  committed
  01c999e

Commits on Apr 20, 2017

• [MINOR][SS] Fix a missing space in UnsupportedOperationChecker error message

  Show description for 39e303a
  zsxwing

  committed
  39e303a

Commits on Apr 19, 2017

• [SPARK-20397][SPARKR][SS] Fix flaky test: test_streaming.R.Terminated by error

  Show description for 4fea784
  zsxwing

  committed
  4fea784

Commits on Apr 13, 2017

• [SPARK-20131][CORE] Don't use this lock in StandaloneSchedulerBackend.stop

  Show description for c5f1cc3
  zsxwing

  committed
  c5f1cc3

Commits on Apr 11, 2017

• [SPARK-17564][TESTS] Fix flaky RequestTimeoutIntegrationSuite.furtherRequestsDelay

  Show description for 734dfbf
  

  zsxwing

  authored and

  rxin

  committed
  734dfbf

Commits on Apr 10, 2017

• [SPARK-20282][SS][TESTS] Write the commit log first to fix a race contion in tests

  Show description for a35b9d9
  zsxwing

  committed
  a35b9d9

• [SPARK-20285][TESTS] Increase the pyspark streaming test timeout to 30 seconds

  Show description for f9a50ba
  zsxwing

  committed
  f9a50ba

Commits on Mar 17, 2017

• [SPARK-19986][TESTS] Make pyspark.streaming.tests.CheckpointTests more stable

  Show description for 376d782
  

  zsxwing

  authored and

  tdas

  committed
  376d782

Commits on Mar 9, 2017

• [SPARK-19874][BUILD] Hide API docs for org.apache.spark.sql.internal

  Show description for 029e40b
  zsxwing

  committed
  029e40b

Commits on Mar 8, 2017

• [SPARK-19858][SS] Add output mode to flatMapGroupsWithState and disallow invalid cases

  Show description for 1bf9012
  

  zsxwing

  authored and

  tdas

  committed
  1bf9012

• [SPARK-19859][SS] The new watermark should override the old one

  Show description for d8830c5
  zsxwing

  committed
  d8830c5

• [SPARK-19841][SS] watermarkPredicate should filter based on keys

  Show description for ca849ac
  zsxwing

  committed
  ca849ac

Commits on Mar 4, 2017

• [SPARK-19816][SQL][TESTS] Fix an issue that DataFrameCallbackSuite doesn't recover the log level

  Show description for fbc4058
  

  zsxwing

  authored and

  gatorsmile

  committed
  fbc4058

• [SPARK-19718][SS] Handle more interrupt cases properly for Hadoop

  Show description for a6a7a95
  zsxwing

  committed
  a6a7a95

Commits on Feb 23, 2017

• [SPARK-19497][SS] Implement streaming deduplication

  Show description for 9bf4e2b
  

  zsxwing

  authored and

  tdas

  committed
  9bf4e2b

Pagination

PreviousNext