From 77d62d9ef0945852de3e60f9d7d07d0bfe918dcd Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Wed, 15 Dec 2021 20:46:42 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= 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 aefbf202..06ce2f7c 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: 100}) + tasksResp, err := rpcClient.NodeTaskRPC().FindNotifyingNodeTasks(ctx, &pb.FindNotifyingNodeTasksRequest{Size: 200}) if err != nil { return err }