Skip to content

Commit

Permalink
CRU
Browse files Browse the repository at this point in the history
  • Loading branch information
keith-turner committed Dec 11, 2015
1 parent 2d2ff5f commit 3e317ff
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,8 @@ public class TableOperations {
private static final String RGB_DEFAULT_PROP = "table.custom.balancer.group.regex.default";
private static final String TABLE_BALANCER_PROP = "table.balancer";

private static final Logger logger = LoggerFactory.getLogger(TableOperations.class);

private static Connector getConnector(FluoConfiguration fluoConfig) throws Exception {

ZooKeeperInstance zki =
Expand Down Expand Up @@ -105,8 +107,8 @@ public static void optimizeTable(FluoConfiguration fluoConfig, Pirtos pirtos) th
conn.tableOperations().setProperty(table, RGB_DEFAULT_PROP, "none");
conn.tableOperations().setProperty(table, TABLE_BALANCER_PROP, RGB_CLASS);
} catch (AccumuloException e) {
LoggerFactory.getLogger(TableOperations.class).warn(
"Unable to setup regex balancer (this is expected to fail in Accumulo 1.6.X) ", e);
logger.warn("Unable to setup regex balancer (this is expected to fail in Accumulo 1.6.X) ",
e);
}
}
}
Expand All @@ -123,8 +125,6 @@ public static void compactTransient(FluoConfiguration fluoConfig) throws Excepti
TransientRegistry transientRegistry = new TransientRegistry(appConfig);
List<RowRange> ranges = transientRegistry.getTransientRanges();

Logger logger = LoggerFactory.getLogger(TableOperations.class);

for (RowRange r : ranges) {
logger.debug("Compacting {} {}", r.getStart(), r.getEnd());
conn.tableOperations().compact(fluoConfig.getAccumuloTable(),
Expand Down

0 comments on commit 3e317ff

Please sign in to comment.