diff --git a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java index 1a93e26ed848..4c33c362b323 100644 --- a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java +++ b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java @@ -33,6 +33,7 @@ import java.util.List; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletionException; +import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.atomic.AtomicBoolean; @@ -228,7 +229,7 @@ public BlockOutputStream( totalWriteChunkLength = 0; totalPutBlockLength = 0; writtenDataLength = 0; - failedServers = new ArrayList<>(0); + failedServers = new CopyOnWriteArrayList<>(); ioException = new AtomicReference<>(null); this.checksum = new Checksum(config.getChecksumType(), config.getBytesPerChecksum(), true); this.clientMetrics = clientMetrics;