Set<TableReference> tables = KeyValueServiceMigrators.getMigratableTableNames(fromKvs, unmigratableTables);
TransactionManager txManager = toTransactionManager;
TransactionManager readTxManager = fromTransactionManager;
GeneralTaskCheckpointer checkpointer =
new GeneralTaskCheckpointer(checkpointTable, toKvs, txManager);
<BUG>ExecutorService executor = PTExecutors.newFixedThreadPool(threads);
</BUG>
try {
migrateTables(
tables,

Set<TableReference> tables = KeyValueServiceMigrators.getMigratableTableNames(fromKvs, unmigratableTables);
TransactionManager txManager = toTransactionManager;
TransactionManager readTxManager = fromTransactionManager;
GeneralTaskCheckpointer checkpointer =
new GeneralTaskCheckpointer(checkpointTable, toKvs, txManager);
ExecutorService executor = Tracers.wrap(PTExecutors.newFixedThreadPool(threads));
try {
migrateTables(
tables,
