Commits

Branch selector

 master

User selector

tdas

Datepicker

All time

Commit History

Commits on Mar 12, 2015

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

  Show description for cd3b68d
  tdas

  committed
  cd3b68d

  Copy full SHA for cd3b68d

Commits on Mar 11, 2015

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

  Show description for 51a79a7
  tdas

  committed
  51a79a7

  Copy full SHA for 51a79a7

Commits on Mar 3, 2015

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

  Show description for 9eb22ec
  tdas

  committed
  9eb22ec

  Copy full SHA for 9eb22ec

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
  aa63f63

  Copy full SHA for aa63f63

Commits on Feb 25, 2015

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

  Show description for 922b43b
  tdas

  committed
  922b43b

  Copy full SHA for 922b43b

Commits on Feb 24, 2015

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

  Show description for 64d2c01
  

  tdas

  authored and

  Andrew Or

  committed
  64d2c01

  Copy full SHA for 64d2c01

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

Pagination

Previous

Next