kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Fix typo in ReplicaVerificationTool output
Date Wed, 05 Aug 2015 23:50:25 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 907ee7b5e -> 9b1c52d52


MINOR: Fix typo in ReplicaVerificationTool output

Author: Andrew Otto <acotto@gmail.com>

Reviewers: Ismael Juma, Guozhang Wang

Closes #101 from ottomata/trunk and squashes the following commits:

10b76f3 [Andrew Otto] MINOR - Fix typo in ReplicaVerificationTool output


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

Branch: refs/heads/trunk
Commit: 9b1c52d52e4e9bbbd89b125fd510bf8b247643ac
Parents: 907ee7b
Author: Andrew Otto <acotto@gmail.com>
Authored: Wed Aug 5 16:51:25 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Wed Aug 5 16:51:25 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/9b1c52d5/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala b/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
index 1366172..fd9daec 100644
--- a/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
+++ b/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
@@ -92,7 +92,7 @@ object ReplicaVerificationTool extends Logging {
                          .describedAs("ms")
                          .ofType(classOf[java.lang.Long])
                          .defaultsTo(30 * 1000L)
-                         
+
    if(args.length == 0)
       CommandLineUtils.printUsageAndDie(parser, "Validate that all replicas for a set of
topics have the same data.")
 
@@ -329,7 +329,7 @@ private class ReplicaBuffer(expectedReplicasPerTopicAndPartition: Map[TopicAndPa
     if (currentTimeMs - lastReportTime > reportInterval) {
       println(ReplicaVerificationTool.dateFormat.format(new Date(currentTimeMs)) + ": max
lag is "
         + maxLag + " for partition " + maxLagTopicAndPartition + " at offset " + offsetWithMaxLag
-        + " among " + messageSetCache.size + " paritions")
+        + " among " + messageSetCache.size + " partitions")
       lastReportTime = currentTimeMs
     }
   }


Mime
View raw message