From 9996f7a4fa4c56c7aaf5973d421aae5c8e2e8f9e Mon Sep 17 00:00:00 2001
From: gaojun2048 <gaojun2048@gmail.com>
Date: Thu, 24 Mar 2022 21:43:13 +0800
Subject: [PATCH] update some method to protected (#9169)

---
 .../dolphinscheduler/service/process/ProcessService.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
index 7913fce8e3..deaf56816b 100644
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
@@ -302,7 +302,7 @@ public class ProcessService {
         return processInstance;
     }
 
-    private void saveSerialProcess(ProcessInstance processInstance, ProcessDefinition processDefinition) {
+    protected void saveSerialProcess(ProcessInstance processInstance, ProcessDefinition processDefinition) {
         processInstance.setState(ExecutionStatus.SERIAL_WAIT);
         saveProcessInstance(processInstance);
         //serial wait
@@ -852,7 +852,7 @@ public class ProcessService {
      * @param host host
      * @return process instance
      */
-    private ProcessInstance constructProcessInstance(Command command, String host) {
+    protected ProcessInstance constructProcessInstance(Command command, String host) {
         ProcessInstance processInstance;
         ProcessDefinition processDefinition;
         CommandType commandType = command.getCommandType();
@@ -2908,7 +2908,7 @@ public class ProcessService {
         return this.processInstanceMapper.loadNextProcess4Serial(code, state);
     }
 
-    private void deleteCommandWithCheck(int commandId) {
+    protected void deleteCommandWithCheck(int commandId) {
         int delete = this.commandMapper.deleteById(commandId);
         if (delete != 1) {
             throw new ServiceException("delete command fail, id:" + commandId);