diff --git a/x-pack/plugins/upgrade_assistant/public/application/components/es_deprecations/deprecation_types/reindex/flyout/checklist_step.tsx b/x-pack/plugins/upgrade_assistant/public/application/components/es_deprecations/deprecation_types/reindex/flyout/checklist_step.tsx index e0b9b25d73235..e416198a69318 100644 --- a/x-pack/plugins/upgrade_assistant/public/application/components/es_deprecations/deprecation_types/reindex/flyout/checklist_step.tsx +++ b/x-pack/plugins/upgrade_assistant/public/application/components/es_deprecations/deprecation_types/reindex/flyout/checklist_step.tsx @@ -109,7 +109,6 @@ export const ChecklistFlyoutStep: React.FunctionComponent<{ )} {(hasFetchFailed || hasReindexingFailed) && ( <> - {reindexState.errorMessage} + )} diff --git a/x-pack/plugins/upgrade_assistant/server/lib/reindexing/reindex_service.ts b/x-pack/plugins/upgrade_assistant/server/lib/reindexing/reindex_service.ts index 00d6e897a1fae..ed02c010ca5d9 100644 --- a/x-pack/plugins/upgrade_assistant/server/lib/reindexing/reindex_service.ts +++ b/x-pack/plugins/upgrade_assistant/server/lib/reindexing/reindex_service.ts @@ -293,12 +293,8 @@ export const reindexServiceFactory = ( // Do any other cleanup work necessary reindexOp = await cleanupChanges(reindexOp); } else { - // Check that it reindexed all documents - const { - body: { count }, - } = await esClient.count({ index: reindexOp.attributes.indexName }); - - if (taskResponse.task.status!.created < count) { + // Check that no failures occurred + if (taskResponse.response?.failures?.length) { // Include the entire task result in the error message. This should be guaranteed // to be JSON-serializable since it just came back from Elasticsearch. throw error.reindexTaskFailed(`Reindexing failed: ${JSON.stringify(taskResponse)}`);