zhanghuidouble opened a new issue #869: [BUG] 工作流实例状态更新判定逻辑有问题
URL: https://github.com/apache/incubator-dolphinscheduler/issues/869
 
 
   *For better global communication, please give priority to using English 
description, thx! *
   
   **Describe the bug**
   
   
   MasterExecThread.runProcess will updateProcessInstanceState after run task , 
 the method of   getProcessInstanceState will check if processFailed ,the code 
is
   
   
![image](https://user-images.githubusercontent.com/28583581/65487160-d76c1e00-ded8-11e9-8ed2-dfd33ac3c1e8.png)
   
   
   
   but One case is that readyToSubmitTaskList.size !=0 but activeTaskNode.size 
= 0
   
   the case like this:
   
   1. create a DAG like this 
   
   
[{"connects":[],"createTime":1569291957000,"desc":"超时失败告警重试","flag":"YES","id":21,"locations":{"tasks-77628":{"targetarr":"","x":195,"name":"失败重试2次","y":431},"tasks-37810":{"targetarr":"","x":250,"name":"超时失败","y":133},"tasks-54599":{"targetarr":"","x":181,"name":"超时告警","y":289}},"name":"超时失败告警重试","processData":{"globalParams":[],"tasks":[{"depList":[],"dependence":"{}","desc":"","forbidden":false,"id":"tasks-37810","maxRetryTimes":0,"name":"超时失败","params":"{\"resourceList\":[],\"localParams\":[],\"rawScript\":\"sleep
 
70\"}","preTasks":"[]","retryInterval":1,"runFlag":"NORMAL","taskInstancePriority":"MEDIUM","taskTimeoutParameter":{"enable":true,"interval":1,"strategy":"FAILED"},"timeout":"{\"strategy\":\"FAILED\",\"interval\":1,\"enable\":true}","type":"SHELL","workerGroupId":"-1"},{"depList":[],"dependence":"{}","desc":"","forbidden":false,"id":"tasks-54599","maxRetryTimes":0,"name":"超时告警","params":"{\"resourceList\":[],\"localParams\":[],\"rawScript\":\"sleep
 
70\"}","preTasks":"[]","retryInterval":1,"runFlag":"NORMAL","taskInstancePriority":"MEDIUM","taskTimeoutParameter":{"enable":true,"interval":1,"strategy":"WARN"},"timeout":"{\"strategy\":\"WARN\",\"interval\":1,\"enable\":true}","type":"SHELL","workerGroupId":"-1"},{"depList":[],"dependence":"{}","desc":"","forbidden":false,"id":"tasks-77628","maxRetryTimes":2,"name":"失败重试2次","params":"{\"resourceList\":[],\"localParams\":[],\"rawScript\":\"风风光光哼哼唧唧黑胡椒\"}","preTasks":"[]","retryInterval":1,"runFlag":"NORMAL","taskInstancePriority":"MEDIUM","taskTimeoutParameter":{"enable":false,"interval":0},"timeout":"{\"strategy\":\"\",\"interval\":null,\"enable\":false}","type":"SHELL","workerGroupId":"-1"}],"timeout":0},"projectId":12,"projectName":"中文qwe123_","receivers":"","receiversCc":"","releaseState":"ONLINE","timeout":0,"updateTime":1569291957000,"userId":"","version":0}]
   
   2.  start
   
   3. the task "失败重试2次"  Expect to retry 2 but only 1 
   
   
   
   **Which version of Easy Scheduler:**
    -[1.1.0-preview]
   
   **Additional context**
   Add any other context about the problem here.
   
   **Requirement or improvement
   - Please describe about your requirements or improvement suggestions.
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to