|
|
@ -22,14 +22,14 @@ import org.apache.dolphinscheduler.common.utils.JSONUtils; |
|
|
|
import java.io.Serializable; |
|
|
|
import java.io.Serializable; |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
/** |
|
|
|
* db task ack request command |
|
|
|
* db task ack request command |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
public class DBTaskAckCommand implements Serializable { |
|
|
|
public class DBTaskAckCommand implements Serializable { |
|
|
|
|
|
|
|
|
|
|
|
private int taskInstanceId; |
|
|
|
private int taskInstanceId; |
|
|
|
private int status; |
|
|
|
private int status; |
|
|
|
|
|
|
|
|
|
|
|
public DBTaskAckCommand(int status,int taskInstanceId) { |
|
|
|
public DBTaskAckCommand(int status, int taskInstanceId) { |
|
|
|
this.status = status; |
|
|
|
this.status = status; |
|
|
|
this.taskInstanceId = taskInstanceId; |
|
|
|
this.taskInstanceId = taskInstanceId; |
|
|
|
} |
|
|
|
} |
|
|
@ -52,9 +52,10 @@ public class DBTaskAckCommand implements Serializable { |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
/** |
|
|
|
* package response command |
|
|
|
* package response command |
|
|
|
|
|
|
|
* |
|
|
|
* @return command |
|
|
|
* @return command |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
public Command convert2Command(){ |
|
|
|
public Command convert2Command() { |
|
|
|
Command command = new Command(); |
|
|
|
Command command = new Command(); |
|
|
|
command.setType(CommandType.DB_TASK_ACK); |
|
|
|
command.setType(CommandType.DB_TASK_ACK); |
|
|
|
byte[] body = JSONUtils.toJsonByteArray(this); |
|
|
|
byte[] body = JSONUtils.toJsonByteArray(this); |
|
|
|