File tree Expand file tree Collapse file tree 1 file changed +8
-6
lines changed
external/kafka/src/main/scala/org/apache/spark/streaming/kafka Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Original file line number Diff line number Diff line change @@ -58,17 +58,19 @@ class ReliableKafkaReceiver[
5858
5959 private val AUTO_OFFSET_COMMIT = " auto.commit.enable"
6060
61- /** A HashMap to manage the offset for each topic/partition, this HashMap is called in
62- * synchronized block, so mutable HashMap will not meet concurrency issue.
63- */
61+ /**
62+ * A HashMap to manage the offset for each topic/partition, this HashMap is called in
63+ * synchronized block, so mutable HashMap will not meet concurrency issue.
64+ */
6465 private var topicPartitionOffsetMap : mutable.HashMap [TopicAndPartition , Long ] = null
6566
6667 /** A concurrent HashMap to store the stream block id and related offset snapshot. */
6768 private var blockOffsetMap : ConcurrentHashMap [StreamBlockId , Map [TopicAndPartition , Long ]] = null
6869
69- /** Manage the BlockGenerator in receiver itself for better managing block store and offset
70- * commit.
71- */
70+ /**
71+ * Manage the BlockGenerator in receiver itself for better managing block store and offset
72+ * commit.
73+ */
7274 private var blockGenerator : BlockGenerator = null
7375
7476 /** Kafka offsets checkpoint listener to register into BlockGenerator for offsets checkpoint. */
You can’t perform that action at this time.
0 commit comments