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 <[email protected]> Authored: Tue Nov 12 09:10:05 2013 -0800 Committer: Matei Zaharia <[email protected]> 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(-) ----------------------------------------------------------------------
