Author: ecn
Date: Mon Dec 12 13:26:36 2011
New Revision: 1213231
URL: http://svn.apache.org/viewvc?rev=1213231&view=rev
Log:
ACCUMULO-213: fix compact table by pattern
Modified:
incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/CompactCommand.java
Modified:
incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/CompactCommand.java
URL:
http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/CompactCommand.java?rev=1213231&r1=1213230&r2=1213231&view=diff
==============================================================================
---
incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/CompactCommand.java
(original)
+++
incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/util/shell/commands/CompactCommand.java
Mon Dec 12 13:26:36 2011
@@ -45,9 +45,9 @@ public class CompactCommand extends Tabl
if (wait)
Shell.log.info("Compacting table ...");
-
shellState.getConnector().tableOperations().compact(shellState.getTableName(),
startRow, endRow, flush, wait);
+ shellState.getConnector().tableOperations().compact(tableName, startRow,
endRow, flush, wait);
- Shell.log.info("Compaction of table " + shellState.getTableName() + " "
+ (wait ? "completed" : "started") + " for given range");
+ Shell.log.info("Compaction of table " + tableName + " " + (wait ?
"completed" : "started") + " for given range");
} catch (Exception ex) {
throw new AccumuloException(ex);
}