Commits

Branch selector

master

User selector

tdas

All time

Commit history

Commits on Jun 2, 2015

• [SPARK-7958] [STREAMING] Handled exception in StreamingContext.start() to prevent leaking of actors

  Show description for 2f9c751
  tdas

  committed
  2f9c751View commit details

  Copy full SHA for 2f9c751

  Browse repository at this point

Commits on May 29, 2015

• [SPARK-7931] [STREAMING] Do not restart receiver when stopped

  Show description for e714ecf
  

  tdas

  authored and

  pwendell

  committed
  e714ecfView commit details

  Copy full SHA for e714ecf

  Browse repository at this point

• [SPARK-7930] [CORE] [STREAMING] Fixed shutdown hook priorities

  Show description for cd3d9a5
  

  tdas

  authored and

  pwendell

  committed
  cd3d9a5View commit details

  Copy full SHA for cd3d9a5

  Browse repository at this point

Commits on May 23, 2015

• [SPARK-7838] [STREAMING] Set scope for kinesis stream

  Show description for baa8983
  

  tdas

  authored and

  Andrew Or

  committed
  baa8983View commit details

  Copy full SHA for baa8983

  Browse repository at this point

• [SPARK-7788] Made KinesisReceiver.onStart() non-blocking

  Show description for 1c388a9
  tdas

  committed
  1c388a9View commit details

  Copy full SHA for 1c388a9

  Browse repository at this point

Commits on May 22, 2015

• [SPARK-7776] [STREAMING] Added shutdown hook to StreamingContext

  Show description for d68ea24
  tdas

  committed
  d68ea24View commit details

  Copy full SHA for d68ea24

  Browse repository at this point

Commits on May 21, 2015

• [SPARK-7478] [SQL] Added SQLContext.getOrCreate

  Show description for 3d0cccc
  tdas

  committed
  3d0ccccView commit details

  Copy full SHA for 3d0cccc

  Browse repository at this point

• [SPARK-7722] [STREAMING] Added Kinesis to style checker

  Show description for 311fab6
  tdas

  committed
  311fab6View commit details

  Copy full SHA for 311fab6

  Browse repository at this point

• [SPARK-7787] [STREAMING] Fix serialization issue of SerializableAWSCredentials

  Show description for 4b7ff30
  tdas

  committed
  4b7ff30View commit details

  Copy full SHA for 4b7ff30

  Browse repository at this point

Commits on May 20, 2015

• [SPARK-7767] [STREAMING] Added test for checkpoint serialization in StreamingContext.start()

  Show description for 3c434cb
  tdas

  committed
  3c434cbView commit details

  Copy full SHA for 3c434cb

  Browse repository at this point

Commits on May 19, 2015

• [SPARK-7692] Updated Kinesis examples

  Show description for 3a60038
  tdas

  committed
  3a60038View commit details

  Copy full SHA for 3a60038

  Browse repository at this point

Commits on May 17, 2015

• [SPARK-6514] [SPARK-5960] [SPARK-6656] [SPARK-7679] [STREAMING] [KINESIS] Updates to the Kinesis API

  Show description for ca4257a
  tdas

  committed
  ca4257aView commit details

  Copy full SHA for ca4257a

  Browse repository at this point

Commits on May 14, 2015

• [SPARK-6752] [STREAMING] [REVISED] Allow StreamingContext to be recreated from checkpoint and existing SparkContext

  Show description for bce00da
  tdas

  committed
  bce00daView commit details

  Copy full SHA for bce00da

  Browse repository at this point

Commits on May 13, 2015

• [SPARK-7554] [STREAMING] Throw exception when an active/stopped StreamingContext is used to create DStreams and output operations

  Show description for 23f7d66
  tdas

  committed
  23f7d66View commit details

  Copy full SHA for 23f7d66

  Browse repository at this point

Commits on May 12, 2015

• [SPARK-7553] [STREAMING] Added methods to maintain a singleton StreamingContext

  Show description for 00e7b09
  tdas

  committed
  00e7b09View commit details

  Copy full SHA for 00e7b09

  Browse repository at this point

• [SPARK-7532] [STREAMING] StreamingContext.start() made to logWarning and not throw exception

  Show description for ec6f2a9
  tdas

  committed
  ec6f2a9View commit details

  Copy full SHA for ec6f2a9

  Browse repository at this point

• [SPARK-7530] [STREAMING] Added StreamingContext.getState() to expose the current state of the context

  Show description for f9c7580
  tdas

  committed
  f9c7580View commit details

  Copy full SHA for f9c7580

  Browse repository at this point

Commits on May 11, 2015

• [SPARK-7361] [STREAMING] Throw unambiguous exception when attempting to start multiple StreamingContexts in the same JVM

  Show description for 1b46556
  tdas

  committed
  1b46556View commit details

  Copy full SHA for 1b46556

  Browse repository at this point

Commits on May 7, 2015

• [SPARK-7217] [STREAMING] Add configuration to control the default behavior of StreamingContext.stop() implicitly calling SparkContext.stop()

  Show description for 01187f5
  tdas

  committed
  01187f5View commit details

  Copy full SHA for 01187f5

  Browse repository at this point

• [SPARK-7430] [STREAMING] [TEST] General improvements to streaming tests to increase debuggability

  Show description for cfdadcb
  tdas

  committed
  cfdadcbView commit details

  Copy full SHA for cfdadcb

  Browse repository at this point

Commits on May 5, 2015

• [HOTFIX] [TEST] Ignoring flaky tests

  Show description for 8776fe0
  tdas

  committed
  8776fe0View commit details

  Copy full SHA for 8776fe0

  Browse repository at this point

• [SPARK-7139] [STREAMING] Allow received block metadata to be saved to WAL and recovered on driver failure

  Show description for 1854ac3
  tdas

  committed
  1854ac3View commit details

  Copy full SHA for 1854ac3

  Browse repository at this point

Commits on May 2, 2015

• [SPARK-7315] [STREAMING] [TEST] Fix flaky WALBackedBlockRDDSuite

  Show description for ecc6eb5
  tdas

  committed
  ecc6eb5View commit details

  Copy full SHA for ecc6eb5

  Browse repository at this point

Commits on Apr 29, 2015

• [SPARK-6752] [STREAMING] [REOPENED] Allow StreamingContext to be recreated from checkpoint and existing SparkContext

  Show description for a9c4e29
  tdas

  committed
  a9c4e29View commit details

  Copy full SHA for a9c4e29

  Browse repository at this point

• [SPARK-7056] [STREAMING] Make the Write Ahead Log pluggable

  Show description for 1868bd4
  tdas

  committed
  1868bd4View commit details

  Copy full SHA for 1868bd4

  Browse repository at this point

• [SPARK-7138] [STREAMING] Add method to BlockGenerator to add multiple records to BlockGenerator with single callback

  Show description for 5c8f4bd
  tdas

  committed
  5c8f4bdView commit details

  Copy full SHA for 5c8f4bd

  Browse repository at this point

Commits on Apr 23, 2015

• [SPARK-6752][Streaming] Allow StreamingContext to be recreated from checkpoint and existing SparkContext

  Show description for 534f2a4
  tdas

  committed
  534f2a4View commit details

  Copy full SHA for 534f2a4

  Browse repository at this point

Commits on Mar 19, 2015

• [SPARK-6222][Streaming] Dont delete checkpoint data when doing pre-batch-start checkpoint

  Show description for 645cf3f
  tdas

  committed
  645cf3fView commit details

  Copy full SHA for 645cf3f

  Browse repository at this point

Commits on Mar 17, 2015

• [SPARK-6331] Load new master URL if present when recovering streaming context from checkpoint

  Show description for c928796
  tdas

  committed
  c928796View commit details

  Copy full SHA for c928796

  Browse repository at this point

Commits on Mar 12, 2015

• [SPARK-6128][Streaming][Documentation] Updates to Spark Streaming Programming Guide

  Show description for cd3b68d
  tdas

  committed
  cd3b68dView commit details

  Copy full SHA for cd3b68d

  Browse repository at this point

Commits on Mar 11, 2015

• [SPARK-6274][Streaming][Examples] Added examples streaming + sql examples.

  Show description for 51a79a7
  tdas

  committed
  51a79a7View commit details

  Copy full SHA for 51a79a7

  Browse repository at this point

Commits on Mar 3, 2015

• [SPARK-6127][Streaming][Docs] Add Kafka to Python api docs

  Show description for 9eb22ec
  tdas

  committed
  9eb22ecView commit details

  Copy full SHA for 9eb22ec

  Browse repository at this point

Commits on Feb 26, 2015

• [SPARK-6027][SPARK-5546] Fixed --jar and --packages not working for KafkaUtils and improved error message

  Show description for aa63f63
  

  tdas

  authored and

  Andrew Or

  committed
  aa63f63View commit details

  Copy full SHA for aa63f63

  Browse repository at this point

Commits on Feb 25, 2015

• [SPARK-5993][Streaming][Build] Fix assembly jar location of kafka-assembly

  Show description for 922b43b
  tdas

  committed
  922b43bView commit details

  Copy full SHA for 922b43b

  Browse repository at this point

Commits on Feb 24, 2015

• [Spark-5967] [UI] Correctly clean JobProgressListener.stageIdToActiveJobIds

  Show description for 64d2c01
  

  tdas

  authored and

  Andrew Or

  committed
  64d2c01View commit details

  Copy full SHA for 64d2c01

  Browse repository at this point