diff --git a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/utils/db/cache/TableCacheImpl.java b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/utils/db/cache/TableCacheImpl.java index 497ab70e3afe..336d633a37c5 100644 --- a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/utils/db/cache/TableCacheImpl.java +++ b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/utils/db/cache/TableCacheImpl.java @@ -101,7 +101,7 @@ public void put(CACHEKEY cacheKey, CACHEVALUE value) { } public void cleanup(List epochs) { - executorService.submit(() -> evictCache(epochs)); + executorService.execute(() -> evictCache(epochs)); } @Override diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/ReplicationSupervisor.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/ReplicationSupervisor.java index 785884cf0723..cb281f062236 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/ReplicationSupervisor.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/ReplicationSupervisor.java @@ -81,7 +81,7 @@ public ReplicationSupervisor( */ public void addTask(ReplicationTask task) { if (containersInFlight.add(task.getContainerId())) { - executor.submit(new TaskRunner(task)); + executor.execute(new TaskRunner(task)); } } diff --git a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/helpers/TestChunkUtils.java b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/helpers/TestChunkUtils.java index 7b9a9796abb0..cb3cdad07e59 100644 --- a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/helpers/TestChunkUtils.java +++ b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/helpers/TestChunkUtils.java @@ -78,7 +78,7 @@ public void concurrentReadOfSameFile() throws Exception { AtomicBoolean failed = new AtomicBoolean(); for (int i = 0; i < threads; i++) { final int threadNumber = i; - executor.submit(() -> { + executor.execute(() -> { try { ByteBuffer readBuffer = ChunkUtils.readData(file, chunkInfo, stats); LOG.info("Read data ({}): {}", threadNumber, @@ -120,7 +120,7 @@ public void concurrentProcessing() throws Exception { for (int i = 0; i < threads; i++) { Path path = Files.createTempFile(PREFIX, String.valueOf(i)); paths.add(path); - executor.submit(() -> { + executor.execute(() -> { ChunkUtils.processFileExclusively(path, () -> { try { Thread.sleep(perThreadWait); diff --git a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java index 95437709a592..ef9940e132fe 100644 --- a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java +++ b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java @@ -292,7 +292,7 @@ public Void call() throws Exception { LOG.info("Buffer size: {} bytes", bufferSize); LOG.info("validateWrites : {}", validateWrites); for (int i = 0; i < numOfThreads; i++) { - executor.submit(new ObjectCreator()); + executor.execute(new ObjectCreator()); } Thread validator = null;