WangJPLeo opened a new pull request, #9955:
URL: https://github.com/apache/dolphinscheduler/pull/9955

   <!--Thanks very much for contributing to Apache DolphinScheduler. Please 
review 
https://dolphinscheduler.apache.org/en-us/community/development/pull-request.html
 before opening a pull request.-->
   
   
   ## Purpose of the pull request
   
   Optimize output logging; distribution failures are visible to users.
   
   ## Brief change log
   
   After the distribution fails, ExecuteException is no longer thrown, and the 
distribution result is returned;
   
   If the distribution result fails, change the current task instance to 
PENDING state, and record the current timestamp as the latest distribution 
failure time;
   
   If the distribution fails, put it into the distribution failure queue 
[isolated from the original queue] and wait for it to be taken out and 
distributed again;
   
   The retry timing is based on the latest dispatch failure time and the 
current interval time is greater than or equal to the specified time and 
increases the number of failed retries;
   
   The server is down: the failover server picks up the workflow instance in 
the specified state -> the mapping task instance submits TASK_STATE_CHANGE [The 
distribution judgment of whether the state is PENDING has been completed in the 
TASK_STATE_CHANGE handle]
   
   close #9401 
   
   ## Verify this pull request
   
   Manually verified the change by testing locally.
   


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to