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());
+ }
+
}
/**