Fix code comment

pinguo-liguo · Sep 29, 2014 · 26c6c9d · 26c6c9d
1 parent 8dc4afe
commit 26c6c9d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/scala/com/miguno/kafkastorm/spark/KafkaSparkStreamingSpec.scala b/src/test/scala/com/miguno/kafkastorm/spark/KafkaSparkStreamingSpec.scala
@@ -193,7 +193,7 @@ class KafkaSparkStreamingSpec extends FeatureSpec with Matchers with BeforeAndAf
         val pool = createKafkaProducerPool(kafkaZkCluster.kafka.brokerList, outputTopic.name)
         ssc.sparkContext.broadcast(pool)
       }
-      // Use an accumulator for Bijection/Injection.
+      // We also use a broadcast variable for Bijection/Injection.
       val converter = ssc.sparkContext.broadcast(specificAvroBinaryInjectionForTweet)
 
       // Note: When working on PairDStreams (which we are not doing here) do not forget to import the corresponding