diff --git a/internal/tasks/task_sync_cluster.go b/internal/tasks/task_sync_cluster.go index 06ce2f7c..9a055752 100644 --- a/internal/tasks/task_sync_cluster.go +++ b/internal/tasks/task_sync_cluster.go @@ -51,7 +51,7 @@ func (this *SyncClusterTask) loop() error { } ctx := rpcClient.Context(0) - tasksResp, err := rpcClient.NodeTaskRPC().FindNotifyingNodeTasks(ctx, &pb.FindNotifyingNodeTasksRequest{Size: 200}) + tasksResp, err := rpcClient.NodeTaskRPC().FindNotifyingNodeTasks(ctx, &pb.FindNotifyingNodeTasksRequest{Size: 500}) if err != nil { return err }