this.writeConsistency = writeConsistency;
this.heartbeatExecutorService = null;
}
public synchronized void startBeatingForLock(long lockId) {
Preconditions.checkState(heartbeatExecutorService == null, START_BEATING_ERR_MSG);
<BUG>heartbeatExecutorService = PTExecutors.newSingleThreadScheduledExecutor(

new ThreadFactoryBuilder().setNameFormat("Atlas Schema Lock Heartbeat-" + lockTable + "-%d").build());
</BUG>
heartbeatExecutorService.scheduleAtFixedRate(

this.writeConsistency = writeConsistency;
this.heartbeatExecutorService = null;
}
public synchronized void startBeatingForLock(long lockId) {
Preconditions.checkState(heartbeatExecutorService == null, START_BEATING_ERR_MSG);
heartbeatExecutorService = Tracers.wrap(PTExecutors.newSingleThreadScheduledExecutor(
new ThreadFactoryBuilder().setNameFormat("Atlas Schema Lock Heartbeat-" + lockTable + "-%d").build()));
heartbeatExecutorService.scheduleAtFixedRate(
