From f1069247f8258897a49dd18d55eeadf13acca6a9 Mon Sep 17 00:00:00 2001
From: Duong Nguyen <duongnt.is@gmail.com>
Date: Thu, 2 May 2024 16:04:10 -0700
Subject: [PATCH] HDDS-10780. NullPointerException in watchForCommit

---
 .../java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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);
   }