From 163464013402e41002036de8b16a9de2fd9a6bed Mon Sep 17 00:00:00 2001
From: Kassian Sun <kassiansun@outlook.com>
Date: Wed, 19 Apr 2023 11:33:42 +0800
Subject: [PATCH] [migration] fix partion query nil check

---
 plugin/migration/pipeline.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 {