Adds null check in cluster changed event sweep (opendistro-for-elasti…

…csearch#125)
dbbaughe · Dec 10, 2019 · 5c089d3 · 5c089d3
1 parent 21a9815
commit 5c089d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...lin/com/amazon/opendistroforelasticsearch/indexstatemanagement/ManagedIndexCoordinator.kt b/...lin/com/amazon/opendistroforelasticsearch/indexstatemanagement/ManagedIndexCoordinator.kt
@@ -231,7 +231,7 @@ class ManagedIndexCoordinator(
     @OpenForTesting
     suspend fun sweepClusterChangedEvent(event: ClusterChangedEvent) {
         val indicesDeletedRequests = event.indicesDeleted()
-                    .filter { event.previousState().metaData().index(it).getPolicyID() != null }
+                    .filter { event.previousState().metaData().index(it)?.getPolicyID() != null }
                     .map { deleteManagedIndexRequest(it.uuid) }
 
         /*