You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ma...@apache.org on 2014/05/27 08:32:26 UTC
git commit: Make parallel repairs default (needed to make incremental
repairs work)
Repository: cassandra
Updated Branches:
refs/heads/trunk e228703b8 -> f5ee620bf
Make parallel repairs default (needed to make incremental repairs work)
Patch by marcuse; reviewed by jbellis for CASSANDRA-7250
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f5ee620b
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f5ee620b
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f5ee620b
Branch: refs/heads/trunk
Commit: f5ee620bf9f47194b4326a4194c8d85e35ca4545
Parents: e228703
Author: Marcus Eriksson <ma...@apache.org>
Authored: Tue May 27 08:31:07 2014 +0200
Committer: Marcus Eriksson <ma...@apache.org>
Committed: Tue May 27 08:31:07 2014 +0200
----------------------------------------------------------------------
src/java/org/apache/cassandra/tools/NodeTool.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f5ee620b/src/java/org/apache/cassandra/tools/NodeTool.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/tools/NodeTool.java b/src/java/org/apache/cassandra/tools/NodeTool.java
index 64ebd9e..77f10ec 100644
--- a/src/java/org/apache/cassandra/tools/NodeTool.java
+++ b/src/java/org/apache/cassandra/tools/NodeTool.java
@@ -1583,8 +1583,8 @@ public class NodeTool
@Arguments(usage = "[<keyspace> <cfnames>...]", description = "The keyspace followed by one or many column families")
private List<String> args = new ArrayList<>();
- @Option(title = "parallel", name = {"-par", "--parallel"}, description = "Use -par to carry out a parallel repair")
- private boolean parallel = false;
+ @Option(title = "seqential", name = {"-seq", "--sequential"}, description = "Use -seq to carry out a sequential repair")
+ private boolean sequential = false;
@Option(title = "local_dc", name = {"-local", "--in-local-dc"}, description = "Use -local to only repair against nodes in the same datacenter")
private boolean localDC = false;
@@ -1626,9 +1626,9 @@ public class NodeTool
else if(!specificHosts.isEmpty())
hosts = newArrayList(specificHosts);
if (!startToken.isEmpty() || !endToken.isEmpty())
- probe.forceRepairRangeAsync(System.out, keyspace, !parallel, dataCenters,hosts, startToken, endToken, fullRepair);
+ probe.forceRepairRangeAsync(System.out, keyspace, sequential, dataCenters,hosts, startToken, endToken, fullRepair);
else
- probe.forceRepairAsync(System.out, keyspace, !parallel, dataCenters, hosts, primaryRange, fullRepair, cfnames);
+ probe.forceRepairAsync(System.out, keyspace, sequential, dataCenters, hosts, primaryRange, fullRepair, cfnames);
} catch (Exception e)
{
throw new RuntimeException("Error occurred during repair", e);