gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat: 2.6.0

Browse Source 
1. 优化工作流执行丢弃问题
This commit is contained in:
byteblogs168 2024-01-25 17:41:43 +08:00
parent 97d8656b6b
commit 7883594fda
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/handler/WorkflowBatchHandler.java
View File

@ -215,10 +215,10 @@ public class WorkflowBatchHandler {
// 说明没有后继节点了, 此时需要判断整个DAG是否全部执行完成 // 说明没有后继节点了, 此时需要判断整个DAG是否全部执行完成
List<JobTaskBatch> jobTaskBatches = jobTaskBatchMapper.selectList(new LambdaQueryWrapper<JobTaskBatch>() List<JobTaskBatch> jobTaskBatches = jobTaskBatchMapper.selectList(new LambdaQueryWrapper<JobTaskBatch>()
.eq(JobTaskBatch::getWorkflowTaskBatchId, workflowTaskBatchId) .eq(JobTaskBatch::getWorkflowTaskBatchId, workflowTaskBatchId)
.in(JobTaskBatch::getWorkflowNodeId, graph.nodes()) .in(JobTaskBatch::getWorkflowNodeId, graph.nodes()).orderByDesc(JobTaskBatch::getId)
); );
Map<Long, JobTaskBatch> jobTaskBatchMap = jobTaskBatches.stream().collect(Collectors.toMap(JobTaskBatch::getWorkflowNodeId, i -> i)); Map<Long, JobTaskBatch> jobTaskBatchMap = jobTaskBatches.stream().collect(Collectors.toMap(JobTaskBatch::getWorkflowNodeId, i -> i, (i,j) -> i));
checkWorkflowExecutor(SystemConstants.ROOT, workflowTaskBatchId, graph, jobTaskBatchMap); checkWorkflowExecutor(SystemConstants.ROOT, workflowTaskBatchId, graph, jobTaskBatchMap);
} }

4
easy-retry-server/easy-retry-server-starter/src/main/resources/easyretry.conf
View File

@ -103,7 +103,7 @@ akka {
type = "Dispatcher" type = "Dispatcher"
executor = "thread-pool-executor" executor = "thread-pool-executor"
thread-pool-executor { thread-pool-executor {
core-pool-size-min = 32 core-pool-size-min = 64
core-pool-size-factor = 2.0 core-pool-size-factor = 2.0
core-pool-size-max = 64 core-pool-size-max = 64
} }
@ -114,7 +114,7 @@ akka {
type = "Dispatcher" type = "Dispatcher"
executor = "thread-pool-executor" executor = "thread-pool-executor"
thread-pool-executor { thread-pool-executor {
core-pool-size-min = 64 core-pool-size-min = 128
core-pool-size-factor = 2.0 core-pool-size-factor = 2.0
core-pool-size-max = 128 core-pool-size-max = 128
} }