gabrywu commented on a change in pull request #2761:
URL:
https://github.com/apache/incubator-dolphinscheduler/pull/2761#discussion_r439733365
##########
File path:
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/executor/NettyExecutorManager.java
##########
@@ -133,26 +136,13 @@ public void executeDirectly(ExecutionContext context)
throws ExecuteException {
* @throws ExecuteException if error throws ExecuteException
*/
private void doExecute(final Host host, final Command command) throws
ExecuteException {
- /**
- * retry count，default retry 3
- */
- int retryCount = 3;
- boolean success = false;
- do {
- try {
+ try {
+ RetryerUtils.retryCall(() -> {
nettyRemotingClient.send(host, command);
- success = true;
- } catch (Exception ex) {
- logger.error(String.format("send command : %s to %s error",
command, host), ex);
- retryCount--;
- try {
- Thread.sleep(100);
Review comment:
I think 100 or 1000 makes no sense, and doesn't matter. We can't say
which interval is appropriate.
----------------------------------------------------------------
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]
