import java.util.concurrent.locks.ReentrantReadWriteLock;
public class BackgroundTaskStatusRegistryImpl
implements BackgroundTaskStatusRegistry {
@Override
public BackgroundTaskStatus getBackgroundTaskStatus(long backgroundTaskId) {
<BUG>if (ClusterMasterExecutorUtil.isMaster()) {

Lock lock = _readWriteLock.readLock();</BUG>
lock.lock();
try {

import java.util.concurrent.locks.ReentrantReadWriteLock;
public class BackgroundTaskStatusRegistryImpl
implements BackgroundTaskStatusRegistry {
@Override
public BackgroundTaskStatus getBackgroundTaskStatus(long backgroundTaskId) {
if (!ClusterMasterExecutorUtil.isMaster()) {
return getBackgroundTaskStatusOnMaster(backgroundTaskId);
}
Lock lock = _readWriteLock.readLock();
lock.lock();
try {
