Commits

Branch selector

 master

User selector

tdas

Datepicker

All time

Commit History

Commits on Sep 5, 2015

• [SPARK-10440] [STREAMING] [DOCS] Update python API stuff in the programming guides and python docs

  Show description for 7a4f326
  

  tdas

  authored and

  rxin

  committed
  7a4f326

  Copy full SHA for 7a4f326

Commits on Aug 25, 2015

• [SPARK-10210] [STREAMING] Filter out non-existent blocks before creating BlockRDD

  Show description for 1fc3758
  tdas

  committed
  1fc3758

  Copy full SHA for 1fc3758

Commits on Aug 24, 2015

• [SPARK-9791] [PACKAGE] Change private class to private class to prevent unnecessary classes from showing up in the docs

  Show description for 7478c8b
  tdas

  committed
  7478c8b

  Copy full SHA for 7478c8b

• [SPARK-10142] [STREAMING] Made python checkpoint recovery handle non-local checkpoint paths and existing SparkContexts

  Show description for 053d94f
  tdas

  committed
  053d94f

  Copy full SHA for 053d94f

Commits on Aug 20, 2015

• [SPARK-10128] [STREAMING] Used correct classloader to deserialize WAL data

  Show description for b762f99
  tdas

  committed
  b762f99

  Copy full SHA for b762f99

Commits on Aug 19, 2015

• [SPARK-9967] [SPARK-10099] [STREAMING] Renamed conf spark.streaming.backpressure.{enable-->enabled} and fixed deprecated annotations

  Show description for bc9a0e0
  tdas

  committed
  bc9a0e0

  Copy full SHA for bc9a0e0

• [SPARK-10072] [STREAMING] BlockGenerator can deadlock when the queue of generate blocks fills up to capacity

  Show description for 1aeae05
  tdas

  committed
  1aeae05

  Copy full SHA for 1aeae05

• [SPARK-10098] [STREAMING] [TEST] Cleanup active context after test in FailureSuite

  Show description for 9108eff
  tdas

  committed
  9108eff

  Copy full SHA for 9108eff

Commits on Aug 14, 2015

• [SPARK-9968] [STREAMING] Reduced time spent within synchronized block to prevent lock starvation

  Show description for 18a761e
  tdas

  committed
  18a761e

  Copy full SHA for 18a761e

• [SPARK-9966] [STREAMING] Handle couple of corner cases in PIDRateEstimator

  Show description for f3bfb71
  tdas

  committed
  f3bfb71

  Copy full SHA for f3bfb71

Commits on Aug 11, 2015

• [SPARK-9572] [STREAMING] [PYSPARK] Added StreamingContext.getActiveOrCreate() in Python

  Show description for 5b8bb1b
  tdas

  committed
  5b8bb1b

  Copy full SHA for 5b8bb1b

• [SPARK-9727] [STREAMING] [BUILD] Updated streaming kinesis SBT project name to be more consistent

  Show description for 600031e
  tdas

  committed
  600031e

  Copy full SHA for 600031e

• [SPARK-9640] [STREAMING] [TEST] Do not run Python Kinesis tests when the Kinesis assembly JAR has not been generated

  Show description for 0f90d60
  tdas

  committed
  0f90d60

  Copy full SHA for 0f90d60

Commits on Aug 6, 2015

• [SPARK-9556] [SPARK-9619] [SPARK-9624] [STREAMING] Make BlockGenerator more robust and make all BlockGenerators subscribe to rate limit updates

  Show description for 0a07830
  tdas

  committed
  0a07830

  Copy full SHA for 0a07830

Commits on Aug 5, 2015

• [SPARK-9217] [STREAMING] Make the kinesis receiver reliable by recording sequence numbers

  Show description for c2a71f0
  tdas

  committed
  c2a71f0

  Copy full SHA for c2a71f0

Commits on Jul 30, 2015

• [STREAMING] [TEST] [HOTFIX] Fixed Kinesis test to not throw weird errors when Kinesis tests are enabled without AWS keys

  Show description for 1afdeb7
  tdas

  committed
  1afdeb7

  Copy full SHA for 1afdeb7

Commits on Jul 28, 2015

• [STREAMING] [HOTFIX] Ignore ReceiverTrackerSuite flaky test

  Show description for c5ed369
  tdas

  committed
  c5ed369

  Copy full SHA for c5ed369

Commits on Jul 24, 2015

• [SPARK-9216] [STREAMING] Define KinesisBackedBlockRDDs

  Show description for d249636
  tdas

  committed
  d249636

  Copy full SHA for d249636

Commits on Jul 20, 2015

• [SPARK-9030] [STREAMING] [HOTFIX] Make sure that no attempts to create Kinesis streams is made when no enabled

  Show description for 93eb2ac
  tdas

  committed
  93eb2ac

  Copy full SHA for 93eb2ac

Commits on Jul 17, 2015

• [SPARK-9030] [STREAMING] Add Kinesis.createStream unit tests that actual sends data

  Show description for b13ef77
  tdas

  committed
  b13ef77

  Copy full SHA for b13ef77

Commits on Jul 9, 2015

• [MINOR] [STREAMING] Fix log statements in ReceiverSupervisorImpl

  Show description for 7ce3b81
  

  tdas

  authored and

  Andrew Or

  committed
  7ce3b81

  Copy full SHA for 7ce3b81

Commits on Jun 19, 2015

• [SPARK-7180] [SPARK-8090] [SPARK-8091] Fix a number of SerializationDebugger bugs and limitations

  Show description for 866816e
  

  tdas

  authored and

  Andrew Or

  committed
  866816e

  Copy full SHA for 866816e

Commits on Jun 12, 2015

• [SPARK-7284] [STREAMING] Updated streaming documentation

  Show description for e9471d3
  tdas

  committed
  e9471d3

  Copy full SHA for e9471d3

Commits on Jun 2, 2015

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

  Show description for 2f9c751
  tdas

  committed
  2f9c751

  Copy full SHA for 2f9c751

Commits on May 29, 2015

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

  Show description for e714ecf
  

  tdas

  authored and

  pwendell

  committed
  e714ecf

  Copy full SHA for e714ecf

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

  Show description for cd3d9a5
  

  tdas

  authored and

  pwendell

  committed
  cd3d9a5

  Copy full SHA for cd3d9a5

Commits on May 23, 2015

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

  Show description for baa8983
  

  tdas

  authored and

  Andrew Or

  committed
  baa8983

  Copy full SHA for baa8983

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

  Show description for 1c388a9
  tdas

  committed
  1c388a9

  Copy full SHA for 1c388a9

Commits on May 22, 2015

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

  Show description for d68ea24
  tdas

  committed
  d68ea24

  Copy full SHA for d68ea24

Commits on May 21, 2015

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

  Show description for 3d0cccc
  tdas

  committed
  3d0cccc

  Copy full SHA for 3d0cccc

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

  Show description for 311fab6
  tdas

  committed
  311fab6

  Copy full SHA for 311fab6

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

  Show description for 4b7ff30
  tdas

  committed
  4b7ff30

  Copy full SHA for 4b7ff30

Commits on May 20, 2015

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

  Show description for 3c434cb
  tdas

  committed
  3c434cb

  Copy full SHA for 3c434cb

Commits on May 19, 2015

• [SPARK-7692] Updated Kinesis examples

  Show description for 3a60038
  tdas

  committed
  3a60038

  Copy full SHA for 3a60038

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
  ca4257a

  Copy full SHA for ca4257a

Pagination

Previous

Next