Commits

Branch selector

 master

User selector

tdas

Datepicker

All time

Commit History

Commits on Feb 18, 2015

• [SPARK-5731][Streaming][Test] Fix incorrect test in DirectKafkaStreamSuite

  Show description for 3912d33
  tdas

  committed
  3912d33

  Copy full SHA for 3912d33

Commits on Feb 10, 2015

• [SPARK-4964][Streaming][Kafka] More updates to Exactly-once Kafka stream

  Show description for c151346
  tdas

  committed
  c151346

  Copy full SHA for c151346

Commits on Feb 3, 2015

• [SPARK-5153][Streaming][Test] Increased timeout to deal with flaky KafkaStreamSuite

  Show description for 681f9df
  tdas

  committed
  681f9df

  Copy full SHA for 681f9df

Commits on Jan 22, 2015

• [SPARK-5147][Streaming] Delete the received data WAL log periodically

  Show description for 3027f06
  tdas

  committed
  3027f06

  Copy full SHA for 3027f06

Commits on Dec 11, 2014

• [SPARK-4806] Streaming doc update for 1.2

  Show description for b004150
  tdas

  committed
  b004150

  Copy full SHA for b004150

Commits on Nov 26, 2014

• [SPARK-4612] Reduce task latency and increase scheduling throughput by making configuration initialization lazy

  Show description for e7f4d25
  

  tdas

  authored and

  rxin

  committed
  e7f4d25

  Copy full SHA for e7f4d25

Commits on Nov 25, 2014

• [SPARK-4196][SPARK-4602][Streaming] Fix serialization issue in PairDStreamFunctions.saveAsNewAPIHadoopFiles

  Show description for 8838ad7
  tdas

  committed
  8838ad7

  Copy full SHA for 8838ad7

• [SPARK-4601][Streaming] Set correct call site for streaming jobs so that it is displayed correctly on the Spark UI

  Show description for 69cd53e
  tdas

  committed
  69cd53e

  Copy full SHA for 69cd53e

Commits on Nov 24, 2014

• [SPARK-4518][SPARK-4519][Streaming] Refactored file stream to prevent files from being processed multiple times

  Show description for cb0e9b0
  tdas

  committed
  cb0e9b0

  Copy full SHA for cb0e9b0

Commits on Nov 19, 2014

• [SPARK-4482][Streaming] Disable ReceivedBlockTracker's write ahead log by default

  Show description for 22fc4e7
  tdas

  committed
  22fc4e7

  Copy full SHA for 22fc4e7

Commits on Nov 5, 2014

• [SPARK-4029][Streaming] Update streaming driver to reliably save and recover received block metadata on driver failures

  Show description for 5f13759
  tdas

  committed
  5f13759

  Copy full SHA for 5f13759

Commits on Oct 30, 2014

• [SPARK-4027][Streaming] WriteAheadLogBackedBlockRDD to read received either from BlockManager or WAL in HDFS

  Show description for fb1fbca
  tdas

  committed
  fb1fbca

  Copy full SHA for fb1fbca

• [SPARK-4028][Streaming] ReceivedBlockHandler interface to abstract the functionality of storage of received data

  Show description for 234de92
  tdas

  committed
  234de92

  Copy full SHA for 234de92

• [SPARK-4053][Streaming] Made the ReceiverSuite test more reliable, by fixing block generator throttling

  Show description for 1234258
  

  tdas

  authored and

  Andrew Or

  committed
  1234258

  Copy full SHA for 1234258

Commits on Oct 14, 2014

• [SPARK-3912][Streaming] Fixed flakyFlumeStreamSuite

  Show description for 4d26aca
  tdas

  committed
  4d26aca

  Copy full SHA for 4d26aca

Commits on Oct 2, 2014

• [SPARK-3495] Block replication fails continuously when the replication target node is dead AND [SPARK-3496] Block replication by mistake chooses driver as target

  Show description for 5db78e6
  

  tdas

  authored and

  rxin

  committed
  5db78e6

  Copy full SHA for 5db78e6

Commits on Sep 6, 2014

• [SPARK-2419][Streaming][Docs] More updates to the streaming programming guide

  Show description for baff7e9
  tdas

  committed
  baff7e9

  Copy full SHA for baff7e9

Commits on Sep 4, 2014

• [SPARK-2419][Streaming][Docs] Updates to the streaming programming guide

  Show description for a522407
  tdas

  committed
  a522407

  Copy full SHA for a522407

Commits on Sep 3, 2014

• [SPARK-1981][Streaming][Hotfix] Fixed docs related to kinesis

  Show description for e9bb12b
  tdas

  committed
  e9bb12b

  Copy full SHA for e9bb12b

Commits on Aug 27, 2014

• [SPARK-3139] Made ContextCleaner to not block on shuffles

  Show description for 3e2864e
  

  tdas

  authored and

  pwendell

  committed
  3e2864e

  Copy full SHA for 3e2864e

Commits on Aug 23, 2014

• [SPARK-3169] Removed dependency on spark streaming test from spark flume sink

  Show description for 3004074
  

  tdas

  authored and

  pwendell

  committed
  3004074

  Copy full SHA for 3004074

Commits on Aug 6, 2014

• [SPARK-1022][Streaming][HOTFIX] Fixed zookeeper dependency of Kafka

  Show description for ee7f308
  

  tdas

  authored and

  pwendell

  committed
  ee7f308

  Copy full SHA for ee7f308

Commits on Jul 24, 2014

• [SPARK-2464][Streaming] Fixed Twitter stream stopping bug

  Show description for a45d548
  tdas

  committed
  a45d548

  Copy full SHA for a45d548

Commits on Jun 11, 2014

• [SPARK-1940] Enabling rolling of executor logs, and automatic cleanup of old executor logs

  Show description for 4823bf4
  

  tdas

  authored and

  pwendell

  committed
  4823bf4

  Copy full SHA for 4823bf4

Commits on May 23, 2014

• Updated scripts for auditing releases

  Show description for b2bdd0e
  tdas

  committed
  b2bdd0e

  Copy full SHA for b2bdd0e

Commits on May 20, 2014

• [Hotfix] Blacklisted flaky HiveCompatibility test

  Show description for 7f0cfe4
  tdas

  committed
  7f0cfe4

  Copy full SHA for 7f0cfe4

• [Spark 1877] ClassNotFoundException when loading RDD with serialized objects

  Show description for 52eb54d
  tdas

  committed
  52eb54d

  Copy full SHA for 52eb54d

Commits on May 15, 2014

• [SPARK-1840] SparkListenerBus prints out scary error message when terminated normally

  Show description for ad4e60e
  

  tdas

  authored and

  pwendell

  committed
  ad4e60e

  Copy full SHA for ad4e60e

Commits on May 14, 2014

• Fixed streaming examples docs to use run-example instead of spark-submit

  Show description for 68f28da
  tdas

  committed
  68f28da

  Copy full SHA for 68f28da

Commits on May 9, 2014

• Converted bang to ask to avoid scary warning when a block is removed

  Show description for 32868f3
  tdas

  committed
  32868f3

  Copy full SHA for 32868f3

Commits on May 5, 2014

• [SPARK-1504], [SPARK-1505], [SPARK-1558] Updated Spark Streaming guide

  Show description for a975a19
  tdas

  committed
  a975a19

  Copy full SHA for a975a19

Commits on Apr 28, 2014

• [SPARK-1633][Streaming] Java API unit test and example for custom streaming receiver in Java

  Show description for 1d84964
  tdas

  committed
  1d84964

  Copy full SHA for 1d84964

Commits on Apr 25, 2014

• [SPARK-1617] and [SPARK-1618] Improvements to streaming ui and bug fix to socket receiver

  Show description for cd12dd9
  tdas

  committed
  cd12dd9

  Copy full SHA for cd12dd9

• [SPARK-1592][streaming] Automatically remove streaming input blocks

  Show description for 526a518
  tdas

  committed
  526a518

  Copy full SHA for 526a518

Commits on Apr 23, 2014

• [streaming][SPARK-1578] Removed requirement for TTL in StreamingContext.

  Show description for f3d19a9
  

  tdas

  authored and

  pwendell

  committed
  f3d19a9

  Copy full SHA for f3d19a9

Pagination

Previous

Next