From fbc7fb80a5dce29ff27d1eac8375e5278f0950e5 Mon Sep 17 00:00:00 2001 From: Lang Martin Date: Wed, 5 Jun 2019 10:19:21 -0400 Subject: [PATCH] core_sched batch node deregistration requests --- nomad/core_sched.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/nomad/core_sched.go b/nomad/core_sched.go index 3d691d605..b0af20edb 100644 --- a/nomad/core_sched.go +++ b/nomad/core_sched.go @@ -484,9 +484,9 @@ OUTER: c.logger.Debug("node GC found eligible nodes", "nodes", len(gcNode)) // Call to the leader to issue the reap - for _, nodeID := range gcNode { + for _, ids := range partitionAll(maxIdsPerReap, gcNode) { req := structs.NodeDeregisterRequest{ - NodeID: nodeID, + NodeIDs: ids, WriteRequest: structs.WriteRequest{ Region: c.srv.config.Region, AuthToken: eval.LeaderACL, @@ -494,7 +494,7 @@ OUTER: } var resp structs.NodeUpdateResponse if err := c.srv.RPC("Node.Deregister", &req, &resp); err != nil { - c.logger.Error("node reap failed", "node_id", nodeID, "error", err) + c.logger.Error("node reap failed", "node_ids", ids, "error", err) return err } }