diff --git a/plugin/migration/model.go b/plugin/migration/model.go
index 37fa2d71..1486e482 100644
--- a/plugin/migration/model.go
+++ b/plugin/migration/model.go
@@ -135,7 +135,7 @@ type IndexMigrationSourceConfig struct {
 	ScrollTime  string      `json:"scroll_time"`
 	IndexRename util.MapStr `json:"index_rename,omitempty"`
 	TypeRename  util.MapStr `json:"type_rename,omitempty"`
-	QueryString string      `json:"query_string,omitempty'`
+	QueryString string      `json:"query_string,omitempty"`
 	QueryDSL    util.MapStr `json:"query_dsl,omitempty"`
 
 	// Parition configs
diff --git a/plugin/migration/pipeline.go b/plugin/migration/pipeline.go
index 92798ccf..5b4e39ba 100644
--- a/plugin/migration/pipeline.go
+++ b/plugin/migration/pipeline.go
@@ -987,8 +987,9 @@ func (p *DispatcherProcessor) splitMajorMigrationTask(taskItem *task2.Task) erro
 				FieldName: index.Partition.FieldName,
 				FieldType: index.Partition.FieldType,
 				Step:      index.Partition.Step,
-				//Filter: index.RawFilter,
-				Filter: source.QueryDSL,
+			}
+			if source.QueryDSL != nil {
+				partitionQ.Filter = source.QueryDSL
 			}
 			partitions, err := elastic.GetPartitions(partitionQ, esSourceClient)
 			if err != nil {