You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@spark.apache.org by ma...@apache.org on 2013/11/12 18:10:11 UTC

[2/2] git commit: Merge pull request #164 from tdas/kafka-fix

Merge pull request #164 from tdas/kafka-fix

Made block generator thread safe to fix Kafka bug.

This is a very important bug fix. Data can and was being lost in the kafka due to this.


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/dfd1ebc2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/dfd1ebc2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/dfd1ebc2

Branch: refs/heads/master
Commit: dfd1ebc2d1e5c34a5979648e571302ae81a178f5
Parents: 23b53ef 7ccbbda
Author: Matei Zaharia <ma...@eecs.berkeley.edu>
Authored: Tue Nov 12 09:10:05 2013 -0800
Committer: Matei Zaharia <ma...@eecs.berkeley.edu>
Committed: Tue Nov 12 09:10:05 2013 -0800

----------------------------------------------------------------------
 .../streaming/dstream/NetworkInputDStream.scala |  4 +-
 .../spark/streaming/InputStreamsSuite.scala     | 83 ++++++++++++++++++--
 2 files changed, 80 insertions(+), 7 deletions(-)
----------------------------------------------------------------------