diff --git a/src/Elastic.Markdown/Exporters/Elasticsearch/ElasticsearchMarkdownExporter.cs b/src/Elastic.Markdown/Exporters/Elasticsearch/ElasticsearchMarkdownExporter.cs index 804b46f13..46e5fe457 100644 --- a/src/Elastic.Markdown/Exporters/Elasticsearch/ElasticsearchMarkdownExporter.cs +++ b/src/Elastic.Markdown/Exporters/Elasticsearch/ElasticsearchMarkdownExporter.cs @@ -49,7 +49,8 @@ string indexNamespace ? new BasicAuthentication(username, password) : null, EnableHttpCompression = true, - DebugMode = _endpoint.DebugMode, + //DebugMode = _endpoint.DebugMode, + DebugMode = true, CertificateFingerprint = _endpoint.CertificateFingerprint, ProxyAddress = _endpoint.ProxyAddress, ProxyPassword = _endpoint.ProxyPassword, @@ -161,11 +162,12 @@ private async ValueTask DoDeleteByQuery(string lexicalWriteAlias, Cancel ctx) } }); var reindexUrl = $"/{lexicalWriteAlias}/_delete_by_query?wait_for_completion=false"; - var reindexNewChanges = await _transport.PostAsync(reindexUrl, request, ctx); - var taskId = reindexNewChanges.Body.Get("task"); + var deleteOldLexicalDocs = await _transport.PostAsync(reindexUrl, request, ctx); + var taskId = deleteOldLexicalDocs.Body.Get("task"); if (string.IsNullOrWhiteSpace(taskId)) { _collector.EmitGlobalError($"Failed to delete data in '{lexicalWriteAlias}' not part of batch date: {_batchIndexDate:o}"); + _logger.LogError("Failed to delete data to '{LexicalWriteAlias}' {Response}", lexicalWriteAlias, deleteOldLexicalDocs); return; } _logger.LogInformation("_delete_by_query task id: {TaskId}", taskId); @@ -196,6 +198,7 @@ private async ValueTask DoReindex(PostData request, string lexicalWriteAlias, st var taskId = reindexNewChanges.Body.Get("task"); if (string.IsNullOrWhiteSpace(taskId)) { + _logger.LogError("Failed to reindex {Type} data to '{SemanticWriteAlias}' {Response}", typeOfSync, semanticWriteAlias, reindexNewChanges); _collector.EmitGlobalError($"Failed to reindex {typeOfSync} data to '{semanticWriteAlias}'"); return; }