Commits

Breadcrumbs

History for

on373a376

User selector

All users

Datepicker

All time

Commit History

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-10102] [STREAMING] Fix a race condition that startReceiver may happen before setting trackerState to Started

  Show description for 90273ef
  

  zsxwing

  authored and

  tdas

  committed
  90273ef

  Copy full SHA for 90273ef

• [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 15, 2015

• [HOTFIX] fix duplicated braces

  Show description for 37586e5
  

  Davies Liu

  authored and

  rxin

  committed
  37586e5

  Copy full SHA for 37586e5

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 12, 2015

• [SPARK-9826] [CORE] Fix cannot use custom classes in log4j.properties

  Show description for ab7e721
  

  michellemay

  authored and

  Marcelo Vanzin

  committed
  ab7e721

  Copy full SHA for ab7e721

Commits on Aug 11, 2015

• [SPARK-9801] [STREAMING] Check if file exists before deleting temporary files.

  Show description for 3c9802d
  

  viadea

  authored and

  tdas

  committed
  3c9802d

  Copy full SHA for 3c9802d

Commits on Aug 9, 2015

• Disable JobGeneratorSuite "Do not clear received block data too soon".

  rxin

  committed
  a863348

  Copy full SHA for a863348

Commits on Aug 6, 2015

• [SPARK-9639] [STREAMING] Fix a potential NPE in Streaming JobScheduler

  Show description for 3462090
  

  zsxwing

  authored and

  tdas

  committed
  3462090

  Copy full SHA for 3462090

• [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

• [SPARK-9504] [STREAMING] [TESTS] Fix o.a.s.streaming.StreamingContextSuite.stop gracefully again

  Show description for d34bac0
  

  zsxwing

  authored and

  tdas

  committed
  d34bac0

  Copy full SHA for d34bac0

Commits on Aug 4, 2015

• [SPARK-9534] [BUILD] Enable javac lint for scalac parity; fix a lot of build warnings, 1.5.0 edition

  Show description for 76d7409
  srowen

  committed
  76d7409

  Copy full SHA for 76d7409

Commits on Jul 31, 2015

• [SPARK-9056] [STREAMING] Rename configuration spark.streaming.minRememberDuration to spark.streaming.fileStream.minRememberDuration

  Show description for 060c79a
  

  Sameer Abhyankar

  authored and

  tdas

  committed
  060c79a

  Copy full SHA for 060c79a

• [SPARK-9504] [STREAMING] [TESTS] Use eventually to fix the flaky test

  Show description for d046347
  

  zsxwing

  authored and

  tdas

  committed
  d046347

  Copy full SHA for d046347

• [SPARK-8979] Add a PID based rate estimator

  Show description for 0a1d2ca
  

  dragos

  authored and

  tdas

  committed
  0a1d2ca

  Copy full SHA for 0a1d2ca

• [SPARK-9472] [STREAMING] consistent hadoop configuration, streaming only

  Show description for 9307f56
  

  koeninger

  authored and

  tdas

  committed
  9307f56

  Copy full SHA for 9307f56

Commits on Jul 30, 2015

• [SPARK-9479] [STREAMING] [TESTS] Fix ReceiverTrackerSuite failure for maven build and other potential test failures in Streaming

  Show description for 0dbd696
  

  zsxwing

  authored and

  tdas

  committed
  0dbd696

  Copy full SHA for 0dbd696

Commits on Jul 29, 2015

• [SPARK-8977] [STREAMING] Defines the RateEstimator interface, and impements the RateController

  Show description for 819be46
  

  dragos

  authored and

  tdas

  committed
  819be46

  Copy full SHA for 819be46

Commits on Jul 28, 2015

• [STREAMING] [HOTFIX] Ignore ReceiverTrackerSuite flaky test

  Show description for c5ed369
  tdas

  committed
  c5ed369

  Copy full SHA for c5ed369

• [SPARK-8882] [STREAMING] Add a new Receiver scheduling mechanism

  Show description for daa1964
  

  zsxwing

  authored and

  tdas

  committed
  daa1964

  Copy full SHA for daa1964

Commits on Jul 24, 2015

• [SPARK-9261] [STREAMING] Avoid calling APIs that expose shaded classes.

  Show description for 8399ba1
  

  Marcelo Vanzin

  committed
  8399ba1

  Copy full SHA for 8399ba1

Commits on Jul 22, 2015

• [SPARK-8975] [STREAMING] Adds a mechanism to send a new rate from the driver to the block generator

  Show description for 798dff7
  

  dragos

  authored and

  tdas

  committed
  798dff7

  Copy full SHA for 798dff7

Commits on Jul 17, 2015

• [SPARK-5681] [STREAMING] Move 'stopReceivers' to the event loop to resolve the race condition

  Show description for ad0954f
  

  zsxwing

  authored and

  tdas

  committed
  ad0954f

  Copy full SHA for ad0954f

Commits on Jul 16, 2015

• [SPARK-6304] [STREAMING] Fix checkpointing doesn't retain driver port issue.

  Show description for 031d7d4
  

  jerryshao

  authored and

  tdas

  committed
  031d7d4

  Copy full SHA for 031d7d4

Commits on Jul 15, 2015

• [SPARK-8820] [STREAMING] Add a configuration to set checkpoint dir.

  Show description for f957796
  

  SaintBacchus

  authored and

  tdas

  committed
  f957796

  Copy full SHA for f957796

Commits on Jul 14, 2015

• [SPARK-8962] Add Scalastyle rule to ban direct use of Class.forName; fix existing uses

  Show description for 11e5c37
  

  JoshRosen

  authored and

  rxin

  committed
  11e5c37

  Copy full SHA for 11e5c37

Commits on Jul 13, 2015

• [SPARK-8743] [STREAMING] Deregister Codahale metrics for streaming when StreamingContext is closed

  Show description for b7bcbe2
  

  Neelesh Srinivas Salian

  authored and

  tdas

  committed
  b7bcbe2

  Copy full SHA for b7bcbe2

Commits on Jul 10, 2015

• [SPARK-7977] [BUILD] Disallowing println

  Show description for e14b545
  

  jonalter

  authored and

  srowen

  committed
  e14b545

  Copy full SHA for e14b545

Commits on Jul 9, 2015

• [SPARK-8701] [STREAMING] [WEBUI] Add input metadata in the batch page

  Show description for 1f6b0b1
  

  zsxwing

  authored and

  tdas

  committed
  1f6b0b1

  Copy full SHA for 1f6b0b1

• [SPARK-7419] [STREAMING] [TESTS] Fix CheckpointSuite.recovery with file input stream

  Show description for 88bf430
  

  zsxwing

  authored and

  Andrew Or

  committed
  88bf430

  Copy full SHA for 88bf430

• [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 30, 2015

• [SPARK-8619] [STREAMING] Don't recover keytab and principal configuration within Streaming checkpoint

  Show description for d16a944
  

  SaintBacchus

  authored and

  tdas

  committed
  d16a944

  Copy full SHA for d16a944

Pagination

Previous

Next