|
|
@@ -335,7 +335,7 @@ class ClusterUniqueTask implements Task ,Serializable{
|
|
|
|
|
|
private Mono<Void> operation(OperationMessage message) {
|
|
|
TaskOperation operation=message.operation;
|
|
|
- this.taskState=operation.getState();
|
|
|
+ this.taskState=State.unknown.equals(operation.getState())?this.taskState:operation.getState();
|
|
|
if(isReplica()&&
|
|
|
(this.generatePingMsgDisposable!=null&&!this.generatePingMsgDisposable.isDisposed())){
|
|
|
//当前为任务副本,传递给任务执行者
|