floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[migration] fix partion query nil check

This commit is contained in:
Kassian Sun 2023-04-19 11:33:42 +08:00
parent 46e5bdc77f
commit 1634640134
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
plugin/migration/pipeline.go
View File

@ -987,8 +987,9 @@ func (p *DispatcherProcessor) splitMajorMigrationTask(taskItem *task2.Task) erro
FieldName: index.Partition.FieldName, FieldName: index.Partition.FieldName,
FieldType: index.Partition.FieldType, FieldType: index.Partition.FieldType,
Step: index.Partition.Step, Step: index.Partition.Step,
//Filter: index.RawFilter, }
Filter: source.QueryDSL, if source.QueryDSL != nil {
partitionQ.Filter = source.QueryDSL
} }
partitions, err := elastic.GetPartitions(partitionQ, esSourceClient) partitions, err := elastic.GetPartitions(partitionQ, esSourceClient)
if err != nil { if err != nil {