diff --git a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java index 58a2153352a4..5c7d7480070a 100644 --- a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java +++ b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java @@ -149,7 +149,8 @@ public long updateCommitInfosMap( } else { stream = commitInfoProtos.stream().map(proto -> commitInfoMap .computeIfPresent(RatisHelper.toDatanodeId(proto.getServer()), - (address, index) -> proto.getCommitIndex())); + (address, index) -> proto.getCommitIndex())) + .filter(Objects::nonNull); } return stream.mapToLong(Long::longValue).min().orElse(0); }