Addressing assertion failure, 'downgrading' to Exception - enrich (#7…

…9717) Addressing assertion failure, 'downgrading' to Exception by moving to try catch. Fixes "java.lang.AssertionError: java.lang.AssertionError: callback must handle its own exceptions"
elastic · Oct 25, 2021 · 809c13f · 809c13f
1 parent c10bf9b
commit 809c13f
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/x-pack/plugin/enrich/src/main/java/org/elasticsearch/xpack/enrich/EnrichPolicyRunner.java b/x-pack/plugin/enrich/src/main/java/org/elasticsearch/xpack/enrich/EnrichPolicyRunner.java
@@ -127,11 +127,10 @@ public void run() {
         client.admin().indices().getIndex(getIndexRequest, listener.delegateFailure((l, getIndexResponse) -> {
             try {
                 validateMappings(getIndexResponse);
+                prepareAndCreateEnrichIndex(toMappings(getIndexResponse));
             } catch (Exception e) {
                 l.onFailure(e);
-                return;
             }
-            prepareAndCreateEnrichIndex(toMappings(getIndexResponse));
         }));
     }