From d14cefdfa3f0e9d3e1fb9758bd8fa57272d7ac4a Mon Sep 17 00:00:00 2001
From: Technoboy- <technoboy@yeah.net>
Date: Fri, 20 Dec 2019 22:50:53 +0800
Subject: [PATCH] updates

---
 .../server/master/runner/MasterBaseTaskExecThread.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java
index 62789a9c6d..bc524e28f9 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java
@@ -135,7 +135,7 @@ public class MasterBaseTaskExecThread implements Callable<Boolean> {
                 }
                 if(!submitDB){
                     logger.error("task commit to db failed , task has already retry {} times, please check the database", retryTimes);
-                }else if(!submitDB){
+                }else if(!submitQueue){
                     logger.error("task commit to queue failed , task has already retry {} times, please check the database", retryTimes);
                 }
                 Thread.sleep(commitRetryInterval);