This is an automated email from the ASF dual-hosted git repository.

leonbao pushed a commit to branch 1.3.6-prepare
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/1.3.6-prepare by this push:
     new c907400  [1.3.6-prepare][Mail] Fix send mail failed instead of execute 
sql error #4739 (#4912)
c907400 is described below

commit c907400fd3a2127b4d8470c4edb1d9d565d2278c
Author: Kirs <[email protected]>
AuthorDate: Tue Mar 9 15:55:43 2021 +0800

    [1.3.6-prepare][Mail] Fix send mail failed instead of execute sql error 
#4739 (#4912)
---
 .../dolphinscheduler/server/worker/task/sql/SqlTask.java       | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
index a9f9bb3..687d049 100644
--- 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
+++ 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
@@ -271,9 +271,13 @@ public class SqlTask extends AbstractTask {
         String result = JSONUtils.toJsonString(resultJSONArray);
         logger.debug("execute sql : {}", result);
 
-        sendAttachment(StringUtils.isNotEmpty(sqlParameters.getTitle()) ?
-                        sqlParameters.getTitle(): 
taskExecutionContext.getTaskName() + " query result sets",
-                JSONUtils.toJsonString(resultJSONArray));
+        try {
+            sendAttachment(StringUtils.isNotEmpty(sqlParameters.getTitle()) ? 
sqlParameters.getTitle() : taskExecutionContext.getTaskName() + " query result 
sets",
+                    JSONUtils.toJsonString(resultJSONArray));
+        } catch (Exception e) {
+            logger.warn("sql task sendAttachment error! msg : {} ", 
e.getMessage());
+        }
+
     }
 
     /**

Reply via email to