Update dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkflowInstanceServiceImpl.java

ruanwenjun · Copilot · web-flow · commit 72db50bffaef · 2025-05-09T21:11:49.000+08:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkflowInstanceServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkflowInstanceServiceImpl.java
@@ -1037,7 +1037,7 @@ public List<WorkflowInstance> queryByWorkflowCodeVersionStatus(Long workflowDefi
         return workflowInstanceDao.queryByCondition(
                 queryWrapper -> queryWrapper.eq(WorkflowInstance::getWorkflowDefinitionCode, workflowDefinitionCode)
                         .eq(WorkflowInstance::getWorkflowDefinitionVersion, workflowDefinitionVersion)
-                        .in(WorkflowInstance::getState, states));
+                        .in(WorkflowInstance::getState, Arrays.stream(states).boxed().collect(Collectors.toList())));
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -1037,7 +1037,7 @@ public List<WorkflowInstance> queryByWorkflowCodeVersionStatus(Long workflowDefi`
`1037`	`1037`	`return workflowInstanceDao.queryByCondition(`
`1038`	`1038`	`queryWrapper -> queryWrapper.eq(WorkflowInstance::getWorkflowDefinitionCode, workflowDefinitionCode)`
`1039`	`1039`	`.eq(WorkflowInstance::getWorkflowDefinitionVersion, workflowDefinitionVersion)`
`1040`		`- .in(WorkflowInstance::getState, states));`
	`1040`	`+ .in(WorkflowInstance::getState, Arrays.stream(states).boxed().collect(Collectors.toList())));`
`1041`	`1041`	`}`
`1042`	`1042`
`1043`	`1043`	`/**`