You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm using FluentScheduler to manage jobs in a system that uses Apache Zookeeper for coordination. If the process loses connection to zookeeper, it needs to pause processing. When the connection to zookeeper is reestablished, we need to restart the jobs.
However, we have multiple instances of the process running on the network. Some jobs are done by all instances and some jobs are only to be performed by the elected leader.
Right now, what I'm doing is when a disconnect occurs, execute
I'm using FluentScheduler to manage jobs in a system that uses Apache Zookeeper for coordination. If the process loses connection to zookeeper, it needs to pause processing. When the connection to zookeeper is reestablished, we need to restart the jobs.
However, we have multiple instances of the process running on the network. Some jobs are done by all instances and some jobs are only to be performed by the elected leader.
Right now, what I'm doing is when a disconnect occurs, execute
JobManager.RemoveAllJobs(); JobManager.StopAndBlock();
When the connection is reestablished, can I create a new Registry and call
JobManager.InitializeWithoutStarting(registry);
The text was updated successfully, but these errors were encountered: