diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java index 865756514e..fe1323c4b5 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java @@ -1089,13 +1089,7 @@ public DatanodeInfo[] getDatanodeReport(DatanodeReportType type) DatanodeInfo[] getCachedDatanodeReport(DatanodeReportType type) throws IOException { try { - DatanodeInfo[] dns = this.dnCache.get(type); - if (dns == null) { - LOG.debug("Get null DN report from cache"); - dns = getCachedDatanodeReportImpl(type); - this.dnCache.put(type, dns); - } - return dns; + return this.dnCache.get(type); } catch (ExecutionException e) { LOG.error("Cannot get the DN report for {}", type, e); Throwable cause = e.getCause();