Skip to content

Commit

Permalink
Add link to Tuning Guide
Browse files Browse the repository at this point in the history
  • Loading branch information
miguno committed Sep 30, 2014
1 parent 2357a84 commit 657c09d
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -170,6 +170,7 @@ class KafkaSparkStreamingSpec extends FeatureSpec with Matchers with BeforeAndAf
//
// And yes, the way we do this looks quite strange -- we combine a hardcoded `1` in the topic map with a
// subsequent `(1..N)` construct. But this approach is the recommended way.
// See http://spark.apache.org/docs/1.1.0/streaming-programming-guide.html#reducing-the-processing-time-of-each-batch
val streams = (1 to inputTopic.partitions) map { _ =>
KafkaUtils.createStream[Array[Byte], Array[Byte], DefaultDecoder, DefaultDecoder](
ssc,
Expand Down

0 comments on commit 657c09d

Please sign in to comment.