diff --git a/RFS/src/main/java/org/opensearch/migrations/bulkload/version_os_2_11/IndexCreator_OS_2_11.java b/RFS/src/main/java/org/opensearch/migrations/bulkload/version_os_2_11/IndexCreator_OS_2_11.java index 49ddc5516..0e4d0655c 100644 --- a/RFS/src/main/java/org/opensearch/migrations/bulkload/version_os_2_11/IndexCreator_OS_2_11.java +++ b/RFS/src/main/java/org/opensearch/migrations/bulkload/version_os_2_11/IndexCreator_OS_2_11.java @@ -74,7 +74,7 @@ public CreationResult create( } log.info("Reattempting creation of index '" + index.getName() + "' after removing illegal arguments; " + illegalArguments); - client.createIndex(index.getName(), body, context).isPresent(); + client.createIndex(index.getName(), body, context); } } catch (Exception e) { result.failureType(CreationFailureType.TARGET_CLUSTER_FAILURE);