diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java index 4858bb54349..d954566539e 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java @@ -1019,7 +1019,7 @@ public class BlockPlacementPolicyDefault extends BlockPlacementPolicy { Collection moreThanOne, Collection exactlyOne, Map> rackMap) { - Collection ret = new ArrayList<>(); + Collection ret = new ArrayList(); if (rackMap.size() == 2) { for (List dsi : rackMap.values()) { if (dsi.size() >= 2) {