You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/03/04 05:22:01 UTC
[17/37] git commit: startHighWaterMarksCheckPointThread is never
called; patched by Sriram Subramanian; reviewed by Jun Rao; kafka-758
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 <ju...@gmail.com>
Authored: Mon Feb 18 14:54:28 2013 -0800
Committer: Jun Rao <ju...@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 = {