---
schema_version: "1"
id: 802ac770e11ace19ef5484f41955a0523c548d1eb3651b28f702118b65f4aeb3
title: Using Aggregators in a Cluster
collection: mulesoft
version: current
locale: en-us
portal_url: https://docs.salesforce.com/mulesoft/current/en-us/aggregators-module/latest/aggregators-cluster.md
canonical_url: https://docs.mulesoft.com/aggregators-module/latest/aggregators-cluster
source_site: docs.mulesoft.com
content_type: documentation
content_hash: 8761e3971266b961489cfadd476dbf42b497f9250024555fb4fa7786cd60297d
description: MuleSoft Documentation Site
release: "1.1"
latest: true
---
---
product: Aggregators Module
version: 1.1
is-latest-version: true
---

# Using Aggregators in a Cluster

> For the full documentation index, see: https://docs.mulesoft.com/llms.txt

> [!IMPORTANT] Aggregators don’t work with multiple workers and a persistent object store because
> clustering isn’t available in CloudHub.

Aggregators Module works in a cluster out-of-the-box environment. However, to prevent an unexpected
behavior consider the following:

When an asynchronous aggregation is defined and the first element arrives, it is scheduled in the
primary node of the cluster. Because new values can arrive in any node of the cluster, we need a way
to notify and make the primary node schedule that aggregation. To do that, another task in the
primary node periodically determines whether it is necessary to schedule a new aggregation or not.
This can lead to a problem if the interval between checks for new aggregation scheduling is much
longer than the actual timeout of the aggregation, because the aggregation could be over before it
is scheduled, or there might be errors in the time computation.

To avoid this issue, configure the frequency at which the primary node checks for new aggregations
to schedule. Define this value using either:

- The global configuration property `mule.aggregatorsSchedulingPeriod` (in milliseconds)

- The system property `-M-Dmule.aggregatorsSchedulingPeriod`

For further information about how to configure global or system properties, see the
[configuring properties](https://docs.mulesoft.com/mule-runtime/latest/configuring-properties) documentation.

## See Also

- [Aggregators Module Reference](https://docs.mulesoft.com/aggregators-module/latest/aggregators-module-reference)

- [Salesforce Help](https://help.salesforce.com)