kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [17/37] git commit: startHighWaterMarksCheckPointThread is never called; patched by Sriram Subramanian; reviewed by Jun Rao; kafka-758
Date Mon, 04 Mar 2013 04:22:01 GMT
startHighWaterMarksCheckPointThread is never called; patched by Sriram Subramanian; reviewed
by Jun Rao; kafka-758


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/30f992c5
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/30f992c5
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/30f992c5

Branch: refs/heads/trunk
Commit: 30f992c52dd3aba8cc35c9835df5b5e56581e0d8
Parents: b84168a
Author: Jun Rao <junrao@gmail.com>
Authored: Mon Feb 18 14:54:28 2013 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Mon Feb 18 14:54:28 2013 -0800

----------------------------------------------------------------------
 .../main/scala/kafka/server/ReplicaManager.scala   |    2 ++
 1 files changed, 2 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/30f992c5/core/src/main/scala/kafka/server/ReplicaManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
index 064af6b..1044085 100644
--- a/core/src/main/scala/kafka/server/ReplicaManager.scala
+++ b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -92,6 +92,8 @@ class ReplicaManager(val config: KafkaConfig,
   def startup() {
     // start ISR expiration thread
     kafkaScheduler.scheduleWithRate(maybeShrinkIsr, "isr-expiration-thread-", 0, config.replicaLagTimeMaxMs)
+    // start high watermark checkpoint thread
+    startHighWaterMarksCheckPointThread()
   }
 
   def stopReplica(topic: String, partitionId: Int, deletePartition: Boolean): Short  = {


Mime
View raw message