kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject [10/30] git commit: KAFKA-673 The logic that controls whether to run recovery on the log is reversed. Reviewed by Neha.
Date Tue, 18 Dec 2012 17:44:12 GMT
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 <jay.kreps@gmail.com>
Authored: Sun Dec 16 11:05:50 2012 -0800
Committer: Jay Kreps <jay.kreps@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()


Mime
View raw message