From 6d537bb798f2ffa569f0096c51be8ae468375001 Mon Sep 17 00:00:00 2001
From: liugq <silenceqi@hotmail.com>
Date: Wed, 29 Mar 2023 18:41:20 +0800
Subject: [PATCH] set es_scroll partition_size default value to 1

---
 plugin/migration/pipeline.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugin/migration/pipeline.go b/plugin/migration/pipeline.go
index 5e408cc0..4c9faadc 100644
--- a/plugin/migration/pipeline.go
+++ b/plugin/migration/pipeline.go
@@ -630,7 +630,7 @@ func (p *DispatcherProcessor) handleReadySubTask(taskItem *task2.Task) error {
 									"migration_task_id": taskItem.ID,
 								},
 							},
-							"partition_size": 20,
+							"partition_size": 1,
 							"scroll_time":    getMapValue(cfgm, "source.scroll_time"),
 							"query_dsl":      scrollQueryDsl,
 							"index_rename":   getMapValue(cfgm, "source.index_rename"),