From b34cc85d5c79c2c44c442aeddb9ade6dc782f990 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jose=20Luis=20L=C3=B3pez?= Date: Fri, 31 Jul 2026 08:31:20 +0200 Subject: [PATCH] HDFS-17951. Fix TestFsVolumeList#testAddRplicaProcessorForAddingReplicaInMap by asserting the pool's configured parallelism. ForkJoinPool.getPoolSize() returns the number of worker threads that have spawned, which tracks task demand and varies by environment; getParallelism() deterministically returns the configured pool size the assertion intends to verify. Contains content generated by Claude Code. Generated-by: Claude Code (claude-fable-5) Co-Authored-By: Claude Fable 5 --- .../hdfs/server/datanode/fsdataset/impl/BlockPoolSlice.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/BlockPoolSlice.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/BlockPoolSlice.java index 8c643e9e16acef..6cf3f67361b64d 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/BlockPoolSlice.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/BlockPoolSlice.java @@ -1130,7 +1130,7 @@ protected void compute() { */ @VisibleForTesting public static int getAddReplicaForkPoolSize() { - return addReplicaThreadPool.getPoolSize(); + return addReplicaThreadPool.getParallelism(); } @VisibleForTesting