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

set es_scroll partition_size default value to 1

This commit is contained in:
liugq 2023-03-29 18:41:20 +08:00
parent 4871fbcb12
commit 6d537bb798
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugin/migration/pipeline.go
View File

@ -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"),