You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jk...@apache.org on 2012/12/18 18:44:12 UTC
[10/30] git commit: KAFKA-673 The logic that controls whether to run
recovery on the log is reversed. Reviewed by Neha.
KAFKA-673 The logic that controls whether to run recovery on the log is reversed. Reviewed by Neha.
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f0d26335
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f0d26335
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f0d26335
Branch: refs/heads/trunk
Commit: f0d26335f2aa3397f0fd6125bfd833c331e90ae9
Parents: 3244bca
Author: Jay Kreps <ja...@gmail.com>
Authored: Sun Dec 16 11:05:50 2012 -0800
Committer: Jay Kreps <ja...@gmail.com>
Committed: Sun Dec 16 11:05:50 2012 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/log/LogManager.scala | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/f0d26335/core/src/main/scala/kafka/log/LogManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/log/LogManager.scala b/core/src/main/scala/kafka/log/LogManager.scala
index 1d4f885..5f0148c 100644
--- a/core/src/main/scala/kafka/log/LogManager.scala
+++ b/core/src/main/scala/kafka/log/LogManager.scala
@@ -101,7 +101,7 @@ private[kafka] class LogManager(val config: KafkaConfig,
for(dir <- dirs) {
/* check if this set of logs was shut down cleanly */
val cleanShutDownFile = new File(dir, CleanShutdownFile)
- val needsRecovery = cleanShutDownFile.exists
+ val needsRecovery = !cleanShutDownFile.exists
cleanShutDownFile.delete
/* load the logs */
val subDirs = dir.listFiles()