diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc index 8bfcdea98..49affcaac 100644 --- a/CHANGELOG.next.asciidoc +++ b/CHANGELOG.next.asciidoc @@ -14,6 +14,7 @@ - Update apikey.cache_hit log field name to match convention. {pull}1900[1900] - LoadServerLimits will not overwrite specified limits when loading default/agent number specified values. {issue}1841[1841] {pull}1912[1912] - Use seperate rate limiters for internal and external API listeners. {issue}1859[1859] {pull}1904[1904] +- Fix fleet.migration.total log key overlap {pull}1951[1951] ==== New Features diff --git a/internal/pkg/dl/migration.go b/internal/pkg/dl/migration.go index f38d3c770..a70918d61 100644 --- a/internal/pkg/dl/migration.go +++ b/internal/pkg/dl/migration.go @@ -123,7 +123,6 @@ func applyMigration(ctx context.Context, name string, index string, bulker bulk. Str("fleet.migration.name", name). Int("fleet.migration.es.took", resp.Took). Bool("fleet.migration.es.timed_out", resp.TimedOut). - Int("fleet.migration.total", resp.Total). Int("fleet.migration.updated", resp.Updated). Int("fleet.migration.deleted", resp.Deleted). Int("fleet.migration.batches", resp.Batches). @@ -132,6 +131,7 @@ func applyMigration(ctx context.Context, name string, index string, bulker bulk. Int("fleet.migration.retries.bulk", resp.Retries.Bulk). Int("fleet.migration.retries.search", resp.Retries.Search). Dur("fleet.migration.total.duration", time.Since(start)). + Int("fleet.migration.total.count", resp.Total). Msgf("migration %s done", name) for _, fail := range resp.Failures {