kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [11/37] git commit: PreferredReplicaLeaderElectionCommand has command line error; patched by Jun Rao; reviewed by Maxime Brugidou; kafka-743
Date Mon, 04 Mar 2013 04:22:02 GMT
PreferredReplicaLeaderElectionCommand has command line error; patched by Jun Rao; reviewed
by Maxime Brugidou; kafka-743


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

Branch: refs/heads/trunk
Commit: 2f0df95f796db9049ed2dfc8e1253957e9e0cfd8
Parents: b89fc2b
Author: Jun Rao <junrao@gmail.com>
Authored: Tue Feb 12 07:50:49 2013 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Tue Feb 12 07:50:49 2013 -0800

----------------------------------------------------------------------
 .../kafka/admin/CheckReassignmentStatus.scala      |    2 +-
 .../PreferredReplicaLeaderElectionCommand.scala    |    2 +-
 .../kafka/admin/ReassignPartitionsCommand.scala    |    2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/2f0df95f/core/src/main/scala/kafka/admin/CheckReassignmentStatus.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/admin/CheckReassignmentStatus.scala b/core/src/main/scala/kafka/admin/CheckReassignmentStatus.scala
index e1d99d2..9e8ccc3 100644
--- a/core/src/main/scala/kafka/admin/CheckReassignmentStatus.scala
+++ b/core/src/main/scala/kafka/admin/CheckReassignmentStatus.scala
@@ -11,7 +11,7 @@ object CheckReassignmentStatus extends Logging {
 
   def main(args: Array[String]): Unit = {
     val parser = new OptionParser
-    val jsonFileOpt = parser.accepts("path to json file", "REQUIRED: The JSON file with the
list of partitions and the " +
+    val jsonFileOpt = parser.accepts("path-to-json-file", "REQUIRED: The JSON file with the
list of partitions and the " +
       "new replicas they should be reassigned to")
       .withRequiredArg
       .describedAs("partition reassignment json file path")

http://git-wip-us.apache.org/repos/asf/kafka/blob/2f0df95f/core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala b/core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala
index a2a4ff3..7b40019 100644
--- a/core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala
+++ b/core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala
@@ -26,7 +26,7 @@ object PreferredReplicaLeaderElectionCommand extends Logging {
 
   def main(args: Array[String]): Unit = {
     val parser = new OptionParser
-    val jsonFileOpt = parser.accepts("path to json file", "The JSON file with the list of
partitions " +
+    val jsonFileOpt = parser.accepts("path-to-json-file", "The JSON file with the list of
partitions " +
       "for which preferred replica leader election should be done, in the following format
- \n" +
        "[{\"topic\": \"foo\", \"partition\": \"1\"}, {\"topic\": \"foobar\", \"partition\":
\"2\"}]. \n" +
       "Defaults to all existing partitions")

http://git-wip-us.apache.org/repos/asf/kafka/blob/2f0df95f/core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala b/core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
index 6b6b1bd..f7e7b72 100644
--- a/core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
+++ b/core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
@@ -26,7 +26,7 @@ object ReassignPartitionsCommand extends Logging {
 
   def main(args: Array[String]): Unit = {
     val parser = new OptionParser
-    val jsonFileOpt = parser.accepts("path to json file", "REQUIRED: The JSON file with the
list of partitions and the " +
+    val jsonFileOpt = parser.accepts("path-to-json-file", "REQUIRED: The JSON file with the
list of partitions and the " +
       "new replicas they should be reassigned to in the following format - \n" +
        "[{\"topic\": \"foo\", \"partition\": \"1\", \"replicas\": \"1,2,3\" }]")
       .withRequiredArg


Mime
View raw message