The Data Integration Service uses a distributed queue to store job information when big data recovery is enabled. The distributed queue is stored in the Model repository and is shared by all other nodes in the grid.
Any available node
can run a job from the queue. If there is a long-running job on a node, another node can pick up jobs that are waiting to run.
Consider the following queueing process for distributed queues:
A client submits a job request to the Data Integration Service, which stores job metadata in the distributed queue.
When the Data Integration Service node has available resources, the Data Integration Service retrieves the job from the queue and sends it to the available node for processing.
If a node fails while running a job, the job can fail over to another node. Any back-up node or node in the grid can take jobs from the queue.