for (TServerInstance tsi : serversToFlush.keySet()) {
try {
final TServerConnection server = master.getConnection(tsi);
if (server != null)
server.compact(master.getMasterLock(), tableId, startRow, endRow);
} catch (TException ex) {
Logger.getLogger(CompactionDriver.class).error(ex.toString());
}
}