Commits

Branch selector

 master

User selector

zsxwing

Datepicker

All time

Commit History

Commits on Jan 15, 2017

• [SPARK-18971][CORE] Upgrade Netty to 4.0.43.Final

  Show description for a8567e3
  

  zsxwing

  authored and

  srowen

  committed
  a8567e3

  Copy full SHA for a8567e3

Commits on Jan 11, 2017

• [SPARK-19140][SS] Allow update mode for non-aggregation streaming queries

  Show description for bc6c56e
  zsxwing

  committed
  bc6c56e

  Copy full SHA for bc6c56e

Commits on Jan 10, 2017

• [SPARK-19113][SS][TESTS] Set UncaughtExceptionHandler in onQueryStarted to ensure catching fatal errors during query initialization

  Show description for 3ef183a
  

  zsxwing

  authored and

  srowen

  committed
  3ef183a

  Copy full SHA for 3ef183a

Commits on Jan 1, 2017

• [SPARK-19050][SS][TESTS] Fix EventTimeWatermarkSuite 'delay in months and years handled correctly'

  Show description for 2394047
  zsxwing

  committed
  2394047

  Copy full SHA for 2394047

Commits on Dec 26, 2016

• [SPARK-17755][CORE] Use workerRef to send RegisterWorkerResponse to avoid the race condition

  Show description for 7026ee2
  zsxwing

  committed
  7026ee2

  Copy full SHA for 7026ee2

Commits on Dec 23, 2016

• [SPARK-18991][CORE] Change ContextCleaner.referenceBuffer to use ConcurrentHashMap to make it faster

  Show description for a848f0b
  zsxwing

  committed
  a848f0b

  Copy full SHA for a848f0b

• [SPARK-18972][CORE] Fix the netty thread names for RPC

  Show description for f252cb5
  zsxwing

  committed
  f252cb5

  Copy full SHA for f252cb5

• [SPARK-18985][SS] Add missing @InterfaceStability.Evolving for Structured Streaming APIs

  Show description for 2246ce8
  zsxwing

  committed
  2246ce8

  Copy full SHA for 2246ce8

Commits on Dec 22, 2016

• [SPARK-18908][SS] Creating StreamingQueryException should check if logicalPlan is created

  Show description for ff7d82a
  zsxwing

  committed
  ff7d82a

  Copy full SHA for ff7d82a

Commits on Dec 21, 2016

• [SPARK-18588][SS][KAFKA] Create a new KafkaConsumer when error happens to fix the flaky test

  Show description for 95efc89
  

  zsxwing

  authored and

  tdas

  committed
  95efc89

  Copy full SHA for 95efc89

• [SPARK-18954][TESTS] Fix flaky test: o.a.s.streaming.BasicOperationsSuite rdd cleanup - map and window

  Show description for 078c71c
  zsxwing

  committed
  078c71c

  Copy full SHA for 078c71c

• [SPARK-18031][TESTS] Fix flaky test ExecutorAllocationManagerSuite.basic functionality

  Show description for ccfe60a
  

  zsxwing

  authored and

  tdas

  committed
  ccfe60a

  Copy full SHA for ccfe60a

Commits on Dec 16, 2016

• [SPARK-18904][SS][TESTS] Merge two FileStreamSourceSuite files

  Show description for 4faa8a3
  zsxwing

  committed
  4faa8a3

  Copy full SHA for 4faa8a3

• [SPARK-18850][SS] Make StreamExecution and progress classes serializable

  Show description for d7f3058
  

  zsxwing

  authored and

  tdas

  committed
  d7f3058

  Copy full SHA for d7f3058

Commits on Dec 15, 2016

• [SPARK-18826][SS] Add 'latestFirst' option to FileStreamSource

  Show description for 68a6dc9
  

  zsxwing

  authored and

  tdas

  committed
  68a6dc9

  Copy full SHA for 68a6dc9

Commits on Dec 14, 2016

• [SPARK-18852][SS] StreamingQuery.lastProgress should be null when recentProgress is empty

  Show description for 1ac6567
  zsxwing

  committed
  1ac6567

  Copy full SHA for 1ac6567

• [SPARK-18588][TESTS] Ignore KafkaSourceStressForDontFailOnDataLossSuite

  Show description for e104e55
  

  zsxwing

  authored and

  rxin

  committed
  e104e55

  Copy full SHA for e104e55

Commits on Dec 13, 2016

• [SPARK-13747][CORE] Fix potential ThreadLocal leaks in RPC when using ForkJoinPool

  Show description for fb3081d
  

  zsxwing

  authored and

  yhuai

  committed
  fb3081d

  Copy full SHA for fb3081d

• [SPARK-18796][SS] StreamingQueryManager should not block when starting a query

  Show description for 417e45c
  

  zsxwing

  authored and

  tdas

  committed
  417e45c

  Copy full SHA for 417e45c

Commits on Dec 8, 2016

• [SPARK-18751][CORE] Fix deadlock when SparkContext.stop is called in Utils.tryOrStopSparkContext

  Show description for 26432df
  zsxwing

  committed
  26432df

  Copy full SHA for 26432df

• [SPARK-18774][CORE][SQL] Ignore non-existing files when ignoreCorruptFiles is enabled

  Show description for b47b892
  

  zsxwing

  authored and

  rxin

  committed
  b47b892

  Copy full SHA for b47b892

Commits on Dec 7, 2016

• [SPARK-18588][TESTS] Fix flaky test: KafkaSourceStressForDontFailOnDataLossSuite

  Show description for edc87e1
  

  zsxwing

  authored and

  tdas

  committed
  edc87e1

  Copy full SHA for edc87e1

• [SPARK-18764][CORE] Add a warning log when skipping a corrupted file

  Show description for dbf3e29
  zsxwing

  committed
  dbf3e29

  Copy full SHA for dbf3e29

Commits on Dec 6, 2016

• [SPARK-18744][CORE] Remove workaround for Netty memory leak

  Show description for eeed38e
  zsxwing

  committed
  eeed38e

  Copy full SHA for eeed38e

• [SPARK-18721][SS] Fix ForeachSink with watermark + append

  Show description for 7863c62
  

  zsxwing

  authored and

  tdas

  committed
  7863c62

  Copy full SHA for 7863c62

• [SPARK-18722][SS] Move no data rate limit from StreamExecution to ProgressReporter

  Show description for 4af142f
  

  zsxwing

  authored and

  tdas

  committed
  4af142f

  Copy full SHA for 4af142f

• [SPARK-18729][SS] Move DataFrame.collect out of synchronized block in MemorySink

  Show description for 1b2785c
  

  zsxwing

  authored and

  tdas

  committed
  1b2785c

  Copy full SHA for 1b2785c

Commits on Dec 5, 2016

• [SPARK-18694][SS] Add StreamingQuery.explain and exception to Python and fix StreamingQueryException

  Show description for 2460128
  

  zsxwing

  authored and

  tdas

  committed
  2460128

  Copy full SHA for 2460128

Commits on Dec 2, 2016

• [SPARK-18670][SS] Limit the number of StreamingQueryListener.StreamProgressEvent when there is no data

  Show description for 56a503d
  

  zsxwing

  authored and

  tdas

  committed
  56a503d

  Copy full SHA for 56a503d

Commits on Dec 1, 2016

• [SPARK-18617][SPARK-18560][TESTS] Fix flaky test: StreamingContextSuite. Receiver data should be deserialized properly

  Show description for 086b0c8
  zsxwing

  committed
  086b0c8

  Copy full SHA for 086b0c8

• [SPARK-18617][SPARK-18560][TEST] Fix flaky test: StreamingContextSuite. Receiver data should be deserialized properly

  Show description for 0a81121
  

  zsxwing

  authored and

  rxin

  committed
  0a81121

  Copy full SHA for 0a81121

• [SPARK-18655][SS] Ignore Structured Streaming 2.0.2 logs in history server

  Show description for c4979f6
  zsxwing

  committed
  c4979f6

  Copy full SHA for c4979f6

Commits on Nov 29, 2016

• [SPARK-18588][SS][KAFKA] Ignore the flaky kafka test

  Show description for 1633ff3
  zsxwing

  committed
  1633ff3

  Copy full SHA for 1633ff3

Commits on Nov 24, 2016

• [SPARK-18510][SQL] Follow up to address comments in apache#15951

  Show description for 223fa21
  

  zsxwing

  authored and

  tdas

  committed
  223fa21

  Copy full SHA for 223fa21

Commits on Nov 23, 2016

• [SPARK-18530][SS][KAFKA] Change Kafka timestamp column type to TimestampType

  Show description for d0212eb
  zsxwing

  committed
  d0212eb

  Copy full SHA for d0212eb

Pagination

Previous

Next