From 7177cdabd55e2a1d89dc9b768f7b8d4e9058da47 Mon Sep 17 00:00:00 2001 From: andy Date: Tue, 13 Aug 2024 17:24:17 +0800 Subject: [PATCH] solve ctx is nil when use IndexPattern --- service/bulkmigrator.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/service/bulkmigrator.go b/service/bulkmigrator.go index 5513bfa..08441b1 100644 --- a/service/bulkmigrator.go +++ b/service/bulkmigrator.go @@ -169,12 +169,14 @@ func (m *BulkMigrator) WithPatternIndexes(pattern string) *BulkMigrator { } newBulkMigrator := &BulkMigrator{ + ctx: m.ctx, SourceES: m.SourceES, TargetES: m.TargetES, Parallelism: m.Parallelism, IndexPairMap: m.IndexPairMap, Error: m.Error, ScrollSize: m.ScrollSize, + ScrollTime: m.ScrollTime, } var filterIndexes []string @@ -183,7 +185,7 @@ func (m *BulkMigrator) WithPatternIndexes(pattern string) *BulkMigrator { return newBulkMigrator } - var newIndexPairsMap map[string]*config.IndexPair + newIndexPairsMap := make(map[string]*config.IndexPair) for _, index := range filterIndexes { indexPair := &config.IndexPair{ SourceIndex: index,