Commits

Breadcrumbs

History for

on8a75a30

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 2, 2015

• [SPARK-12087][STREAMING] Create new JobConf for every batch in saveAsHadoopFiles

  Show description for 8a75a30
  

  tdas

  authored and

  zsxwing

  committed
  8a75a30

Commits on Dec 1, 2015

• [SPARK-12046][DOC] Fixes various ScalaDoc/JavaDoc issues

  Show description for 69dbe6b
  

  liancheng

  authored and

  marmbrus

  committed
  69dbe6b

Commits on Nov 27, 2015

• [SPARK-12021][STREAMING][TESTS] Fix the potential dead-lock in StreamingListenerSuite

  Show description for f57e6c9
  zsxwing

  committed
  f57e6c9

Commits on Nov 25, 2015

• [SPARK-11935][PYSPARK] Send the Python exceptions in TransformFunction and TransformFunctionSerializer to Java

  Show description for d29e2ef
  

  zsxwing

  authored and

  tdas

  committed
  d29e2ef

• [SPARK-11979][STREAMING] Empty TrackStateRDD cannot be checkpointed and recovered from checkpoint file

  Show description for 2169886
  

  tdas

  authored and

  zsxwing

  committed
  2169886

• [STREAMING][FLAKY-TEST] Catch execution context race condition in FileBasedWriteAheadLog.close()

  Show description for a5d9887
  

  brkyvz

  authored and

  zsxwing

  committed
  a5d9887

Commits on Nov 20, 2015

• [SPARK-11845][STREAMING][TEST] Added unit test to verify TrackStateRDD is correctly checkpointed

  Show description for b2cecb8
  

  tdas

  authored and

  Andrew Or

  committed
  b2cecb8

Commits on Nov 19, 2015

• [SPARK-11791] Fix flaky test in BatchedWriteAheadLogSuite

  Show description for 921900f
  

  brkyvz

  authored and

  tdas

  committed
  921900f

• [SPARK-11814][STREAMING] Add better default checkpoint duration

  Show description for a402c92
  tdas

  committed
  a402c92

• [SPARK-11495] Fix potential socket / file handle leaks that were found via static analysis

  Show description for 4b11712
  

  JoshRosen

  authored and

  rxin

  committed
  4b11712

Commits on Nov 18, 2015

• [SPARK-4557][STREAMING] Spark Streaming foreachRDD Java API method should accept a VoidFunction<...>

  Show description for 31921e0
  

  BryanCutler

  authored and

  tdas

  committed
  31921e0

• [SPARK-11761] Prevent the call to StreamingContext#stop() in the listener bus's thread

  Show description for 446738e
  

  tedyu

  authored and

  tdas

  committed
  446738e

Commits on Nov 17, 2015

• [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batch

  Show description for 928d631
  

  zsxwing

  authored and

  tdas

  committed
  928d631

Commits on Nov 16, 2015

• [SPARK-11742][STREAMING] Add the failure info to the batch lists

  Show description for bcea0bf
  

  zsxwing

  authored and

  tdas

  committed
  bcea0bf

• [SPARK-6328][PYTHON] Python API for StreamingListener

  Show description for ace0db4
  

  djalova

  authored and

  tdas

  committed
  ace0db4

• [SPARK-11731][STREAMING] Enable batching on Driver WriteAheadLog by default

  Show description for de5e531
  

  brkyvz

  authored and

  tdas

  committed
  de5e531

Commits on Nov 14, 2015

• [SPARK-11573] Correct 'reflective access of structural type member meth…

  Show description for 9461f5e
  

  gliptak

  authored and

  srowen

  committed
  9461f5e

Commits on Nov 13, 2015

• [SPARK-11681][STREAMING] Correctly update state timestamp even when state is not updated

  Show description for e4e46b2
  tdas

  committed
  e4e46b2

• [SPARK-11419][STREAMING] Parallel recovery for FileBasedWriteAheadLog + minor recovery tweaks

  Show description for 7786f9c
  

  brkyvz

  authored and

  tdas

  committed
  7786f9c

• [SPARK-11663][STREAMING] Add Java API for trackStateByKey

  Show description for 0f1d00a
  

  zsxwing

  authored and

  tdas

  committed
  0f1d00a

Commits on Nov 12, 2015

• [SPARK-11290][STREAMING][TEST-MAVEN] Fix the test for maven build

  Show description for f0d3b58
  

  zsxwing

  authored and

  tdas

  committed
  f0d3b58

Commits on Nov 11, 2015

• [SPARK-11639][STREAMING][FLAKY-TEST] Implement BlockingWriteAheadLog for testing the BatchedWriteAheadLog

  Show description for 27029bc
  

  brkyvz

  authored and

  tdas

  committed
  27029bc

• [SPARK-11290][STREAMING] Basic implementation of trackStateByKey

  Show description for 99f5f98
  tdas

  committed
  99f5f98

• [SPARK-11361][STREAMING] Show scopes of RDD operations inside DStream.foreachRDD and DStream.transform in DAG viz

  Show description for 6600786
  

  tdas

  authored and

  Andrew Or

  committed
  6600786

Commits on Nov 10, 2015

• Add mockito as an explicit test dependency to spark-streaming

  Show description for 1431319
  

  brkyvz

  authored and

  tdas

  committed
  1431319

• [SPARK-11333][STREAMING] Add executorId to ReceiverInfo and display it in UI

  Show description for 6502944
  

  zsxwing

  authored and

  tdas

  committed
  6502944

• [SPARK-11462][STREAMING] Add JavaStreamingListener

  Show description for 1f0f14e
  

  zsxwing

  authored and

  tdas

  committed
  1f0f14e

• [SPARK-11141][STREAMING] Batch ReceivedBlockTrackerLogEvents for WAL writes

  Show description for 0ce6f9b
  

  brkyvz

  authored and

  tdas

  committed
  0ce6f9b

Commits on Nov 6, 2015

• [SPARK-11511][STREAMING] Fix NPE when an InputDStream is not used

  Show description for cf69ce1
  

  zsxwing

  authored and

  srowen

  committed
  cf69ce1

• [SPARK-11457][STREAMING][YARN] Fix incorrect AM proxy filter conf recovery from checkpoint

  Show description for 468ad0a
  

  jerryshao

  authored and

  Marcelo Vanzin

  committed
  468ad0a

Commits on Nov 5, 2015

• [SPARK-11440][CORE][STREAMING][BUILD] Declare rest of @experimental items non-experimental if they've existed since 1.2.0

  Show description for 6f81eae
  srowen

  committed
  6f81eae

Commits on Oct 27, 2015

• [SPARK-11212][CORE][STREAMING] Make preferred locations support ExecutorCacheTaskLocation and update…

  Show description for 9fbd75a
  

  zsxwing

  authored and

  tdas

  committed
  9fbd75a

• [SPARK-11324][STREAMING] Flag for closing Write Ahead Logs after a write

  Show description for 4f030b9
  

  brkyvz

  authored and

  tdas

  committed
  4f030b9

• [SPARK-5569][STREAMING] fix ObjectInputStreamWithLoader for supporting load array classes.

  Show description for 17f4999
  

  maxwell

  authored and

  tdas

  committed
  17f4999

Commits on Oct 26, 2015

• [SPARK-10984] Simplify *MemoryManager class structure

  Show description for 85e654c
  JoshRosen

  committed
  85e654c

Pagination

PreviousNext