Fix dataStreamPreviousMetadata NPE

Signed-off-by: Sandesh Kumar <sandeshkr419@gmail.com>
opensearch-project · Jun 8, 2023 · 35b1c8a · 35b1c8a
1 parent cc41985
commit 35b1c8a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/cluster/metadata/Metadata.java b/server/src/main/java/org/opensearch/cluster/metadata/Metadata.java
@@ -1138,7 +1138,7 @@ public Builder() {
             indicesPreviousState = new HashMap<>();
             templates = new HashMap<>();
             customs = new HashMap<>();
-            dataStreamPreviousMetadata = null;
+            dataStreamPreviousMetadata = DataStreamMetadata.builder().build();
             allIndices = Strings.EMPTY_ARRAY;
             visibleIndices = Strings.EMPTY_ARRAY;
             allOpenIndices = Strings.EMPTY_ARRAY;
@@ -1453,6 +1453,7 @@ public Builder generateClusterUuidIfNeeded() {
 
         public Metadata build() {
             TimeValue buildStartTime = TimeValue.timeValueMillis(System.nanoTime());
+            boolean dataStreamsChanged = dataStreamPreviousMetadata == this.customs.get(DataStreamMetadata.TYPE);
             boolean recomputeRequired = indices.equals(indicesPreviousState) == false || dataStreamPreviousMetadata.equals(this.customs.get(DataStreamMetadata.TYPE)) == false;
             TimeValue recomputeEndTime = TimeValue.timeValueMillis(System.nanoTime());
             logger.info(