@@ -208,9 +208,8 @@ class RuleClusterUniqueTask extends ClusterUniqueTask implements Task ,Serializa
@Override
public void beMasterPostProcessor() {
- if(isReplica()&&this.executor.getState().equals(State.running)){
- this.taskState=State.running;
- this.executor.pause();
+ if(State.running.equals(this.taskState)&&!State.running.equals(this.executor.getState())){
+ this.executor.start();
}