From 657c09d71ea942ae1e223e2ad7749f41f989b11a Mon Sep 17 00:00:00 2001 From: "Michael G. Noll" Date: Tue, 30 Sep 2014 12:03:39 +0200 Subject: [PATCH] Add link to Tuning Guide --- .../com/miguno/kafkastorm/spark/KafkaSparkStreamingSpec.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/src/test/scala/com/miguno/kafkastorm/spark/KafkaSparkStreamingSpec.scala b/src/test/scala/com/miguno/kafkastorm/spark/KafkaSparkStreamingSpec.scala index 697601b..69e7fde 100644 --- a/src/test/scala/com/miguno/kafkastorm/spark/KafkaSparkStreamingSpec.scala +++ b/src/test/scala/com/miguno/kafkastorm/spark/KafkaSparkStreamingSpec.scala @@ -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,