Merge pull request 'set es_scroll partition_size default value to 1' (#44) from fix_partition_size into master

This commit is contained in:
silenceqi 2023-03-29 18:42:19 +08:00
commit 082bed8aa4
1 changed files with 1 additions and 1 deletions

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