[improve-apache#13045] format

fuchanghai · Nov 30, 2022 · e9a6cda · e9a6cda
1 parent 0c139b5
commit e9a6cda
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/.../main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStartEventHandler.java b/.../main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStartEventHandler.java
@@ -20,7 +20,6 @@
 import org.apache.dolphinscheduler.common.enums.StateEventType;
 import org.apache.dolphinscheduler.common.enums.WorkflowExecutionStatus;
 import org.apache.dolphinscheduler.dao.entity.ProcessInstance;
-import org.apache.dolphinscheduler.dao.repository.ProcessInstanceDao;
 import org.apache.dolphinscheduler.server.master.cache.ProcessInstanceExecCacheManager;
 import org.apache.dolphinscheduler.server.master.metrics.ProcessInstanceMetrics;
 import org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread;
@@ -75,9 +74,9 @@ public void handleWorkflowEvent(final WorkflowEvent workflowEvent) throws Workfl
                         logger.error("Failed to submit the workflow instance, will resend the workflow start event: {}",
                                 workflowEvent);
                         workflowEvent.setMaxSubmitTimes(workflowEvent.getMaxSubmitTimes() - 1);
-                        if(workflowEvent.getMaxSubmitTimes() >= 0){
+                        if (workflowEvent.getMaxSubmitTimes() >= 0) {
                             workflowEventQueue.addEvent(workflowEvent);
-                        }else {
+                        } else {
                             WorkflowStateEvent stateEvent = WorkflowStateEvent.builder()
                                     .processInstanceId(processInstance.getId())
                                     .type(StateEventType.PROCESS_SUBMIT_FAILED)

diff --git a/.../main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java b/.../main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java
@@ -59,7 +59,7 @@ public boolean handleStateEvent(WorkflowExecuteRunnable workflowExecuteRunnable,
             return true;
         }
         if (workflowStateEvent.getStatus().isFinished()) {
-            if(workflowStateEvent.getType() == StateEventType.PROCESS_SUBMIT_FAILED){
+            if (workflowStateEvent.getType().equals(StateEventType.PROCESS_SUBMIT_FAILED)) {
                 workflowExecuteRunnable.updateProcessInstanceState(workflowStateEvent);
             }
             workflowExecuteRunnable.endProcess();

diff --git a/.../main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerBootstrap.java b/.../main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerBootstrap.java
@@ -199,7 +199,7 @@ public void run() {
                                 taskDefinitionLogDao);
                         processInstanceExecCacheManager.cache(processInstance.getId(), workflowRunnable);
                         workflowEventQueue.addEvent(new WorkflowEvent(WorkflowEventType.START_WORKFLOW,
-                                processInstance.getId(),masterConfig.getWorkflowMaxSubmitTimes()));
+                                processInstance.getId(), masterConfig.getWorkflowMaxSubmitTimes()));
                     } finally {
                         LoggerUtils.removeWorkflowInstanceIdMDC();
                     }