Fixed es export: ignore_unavailable should be set in PIT (#190)

* Fixed PIT no index found error * Removed duplicate option in es export
myrteametrics · Jun 4, 2024 · 2c87b96 · 2c87b96
1 parent bcaba6e
commit 2c87b96
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/internals/export/elasticsearch.go b/internals/export/elasticsearch.go
@@ -116,7 +116,9 @@ func (export StreamedExport) ProcessStreamedExport(ctx context.Context, params E
 	}
 
 	// handle pit creation
-	pit, err := cli.OpenPointInTime(params.Indices).KeepAlive("5m").Do(context.Background())
+	pit, err := cli.OpenPointInTime(params.Indices).
+		IgnoreUnavailable(params.IgnoreUnavailable).
+		KeepAlive("5m").Do(context.Background())
 	if err != nil {
 		zap.L().Error("OpenPointInTime failed", zap.Error(err))
 		return err
@@ -159,7 +161,6 @@ func (export StreamedExport) ProcessStreamedExport(ctx context.Context, params E
 		response, err := cli.Search().
 			Request(params.SearchRequest).
 			Size(size).
-			IgnoreUnavailable(params.IgnoreUnavailable).
 			AllowNoIndices(params.AllowNoIndices).
 			Do(context.Background())
 		if err != nil {