From 98f3d071c90bdf290af66c1e27b171fb6f8e0cbf Mon Sep 17 00:00:00 2001 From: jerryshao Date: Mon, 10 Nov 2014 15:35:30 +0800 Subject: [PATCH] Fix comment style --- .../streaming/kafka/ReliableKafkaReceiver.scala | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala index 417b0464c1e86..938fcc1fc6a32 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala +++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala @@ -58,17 +58,19 @@ class ReliableKafkaReceiver[ private val AUTO_OFFSET_COMMIT = "auto.commit.enable" - /** A HashMap to manage the offset for each topic/partition, this HashMap is called in - * synchronized block, so mutable HashMap will not meet concurrency issue. - */ + /** + * A HashMap to manage the offset for each topic/partition, this HashMap is called in + * synchronized block, so mutable HashMap will not meet concurrency issue. + */ private var topicPartitionOffsetMap: mutable.HashMap[TopicAndPartition, Long] = null /** A concurrent HashMap to store the stream block id and related offset snapshot. */ private var blockOffsetMap: ConcurrentHashMap[StreamBlockId, Map[TopicAndPartition, Long]] = null - /** Manage the BlockGenerator in receiver itself for better managing block store and offset - * commit. - */ + /** + * Manage the BlockGenerator in receiver itself for better managing block store and offset + * commit. + */ private var blockGenerator: BlockGenerator = null /** Kafka offsets checkpoint listener to register into BlockGenerator for offsets checkpoint. */