Capture exceptions during transformation and log errors

Signed-off-by: Peter Nied <[email protected]>
opensearch-project · Dec 4, 2024 · 04724ff · 04724ff
1 parent e1e03d0
commit 04724ff
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/...n/java/org/opensearch/migrations/bulkload/transformers/Transformer_ES_6_8_to_OS_2_11.java b/...n/java/org/opensearch/migrations/bulkload/transformers/Transformer_ES_6_8_to_OS_2_11.java
@@ -38,8 +38,16 @@ public GlobalMetadata transformGlobalMetadata(GlobalMetadata globalData) {
             templatesRoot.fields().forEachRemaining(template -> {
                 var templateCopy = (ObjectNode) template.getValue().deepCopy();
                 var indexTemplate = (Index) () -> templateCopy;
-                transformIndex(indexTemplate, IndexType.TEMPLATE);
-                templates.set(template.getKey(), indexTemplate.getRawJson());
+                try {
+                    transformIndex(indexTemplate, IndexType.TEMPLATE);
+                    templates.set(template.getKey(), indexTemplate.getRawJson());
+                }  catch (Exception e) {
+                    log.atError()
+                        .setMessage("Unable to transform object: {}")
+                        .addArgument(indexTemplate::getRawJson)
+                        .setCause(e)
+                        .log();
+                }
             });
             newRoot.set("templates", templates);
         }