Skip to content

Commit

Permalink
Remove unused code
Browse files Browse the repository at this point in the history
  • Loading branch information
Haoning-Sun committed Jul 5, 2024
1 parent 76709a1 commit 7ec4cc9
Showing 1 changed file with 0 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@
import static java.util.Objects.requireNonNull;

import alluxio.Sessions;
import alluxio.conf.Configuration;
import alluxio.conf.PropertyKey;
import alluxio.exception.runtime.AlluxioRuntimeException;
import alluxio.exception.runtime.BlockDoesNotExistRuntimeException;
import alluxio.exception.status.AlluxioStatusException;
Expand All @@ -31,7 +29,6 @@
import alluxio.retry.ExponentialBackoffRetry;
import alluxio.retry.RetryUtils;
import alluxio.underfs.UfsManager;
import alluxio.util.ThreadFactoryUtils;
import alluxio.worker.block.DefaultBlockWorker.Metrics;
import alluxio.worker.block.io.BlockReader;
import alluxio.worker.block.io.BlockWriter;
Expand All @@ -54,8 +51,6 @@
import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.atomic.AtomicReference;

/**
Expand All @@ -64,8 +59,6 @@
*/
public class MonoBlockStore implements BlockStore {
private static final Logger LOG = LoggerFactory.getLogger(MonoBlockStore.class);
private static final long LOAD_TIMEOUT =
Configuration.getMs(PropertyKey.USER_NETWORK_RPC_KEEPALIVE_TIMEOUT);
private final LocalBlockStore mLocalBlockStore;
private final UnderFileSystemBlockStore mUnderFileSystemBlockStore;
private final BlockMasterClientPool mBlockMasterClientPool;
Expand All @@ -74,9 +67,6 @@ public class MonoBlockStore implements BlockStore {
private final List<BlockStoreEventListener> mBlockStoreEventListeners =
new CopyOnWriteArrayList<>();

private final ScheduledExecutorService mDelayer =
new ScheduledThreadPoolExecutor(1, ThreadFactoryUtils.build("LoadTimeOut", true));

/**
* Constructor of MonoBlockStore.
*
Expand Down

0 comments on commit 7ec4cc9

Please sign in to comment.