fix NPE

opensearch-project · Apr 24, 2024 · b3774da · b3774da
1 parent db33815
commit b3774da
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/cluster/routing/ShardRouting.java b/server/src/main/java/org/opensearch/cluster/routing/ShardRouting.java
@@ -302,7 +302,8 @@ public ShardIterator shardsIt() {
 
     public ShardRouting(ShardId shardId, StreamInput in) throws IOException {
         this.shardId = shardId;
-        currentNodeId = in.readOptionalString() != null ? in.readOptionalString().intern() : null;
+        String currentNodeIdFromStream = in.readOptionalString();
+        currentNodeId = currentNodeIdFromStream != null ? currentNodeIdFromStream.intern() : null;
         relocatingNodeId = in.readOptionalString();
         primary = in.readBoolean();
         state = ShardRoutingState.fromValue(in.readByte());