From 9239dd9a8bd65a4ff9f4b965526c2a70a701a0eb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Fri, 17 Dec 2021 14:25:40 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E5=8D=95=E6=AC=A1=E9=80=9A?= =?UTF-8?q?=E7=9F=A5=E6=9B=B4=E6=96=B0=E4=BB=BB=E5=8A=A1=E7=9A=84=E6=95=B0?= =?UTF-8?q?=E9=87=8F=E4=B8=BA500=EF=BC=88=E5=8E=9F=E6=9D=A5200=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/tasks/task_sync_cluster.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 }