Browse Source

bug:Catching exceptions and printing exception information (#1457)

* fix:When there are multiple nodes, the monitoring center dashboard displays only one node.

* fix:Catching exceptions and printing exception information

* fix:rollback

* fix:getting project name field bug
魔方不在手 5 years ago
parent
commit
81810f55d5

+ 1 - 1
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ProcessDefinitionService.java

@@ -512,7 +512,7 @@ public class ProcessDefinitionService extends BaseDAGService {
                                     for (int k = 0; k < dependItemList.size(); k++) {
                                         JSONObject dependentItem = dependItemList.getJSONObject(k);
                                         int definitionId = dependentItem.getInteger("definitionId");
-                                        ProcessDefinition definition = processDefineMapper.selectById(definitionId);
+                                        ProcessDefinition definition = processDefineMapper.queryByDefineId(definitionId);
                                         if(definition != null){
                                             dependentItem.put("projectName",definition.getProjectName());
                                             dependentItem.put("definitionName",definition.getName());

+ 3 - 0
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java

@@ -174,6 +174,9 @@ public class SqlTask extends AbstractTask {
 
             // execute sql task
             con = executeFuncAndSql(mainSqlBinds, preStatementSqlBinds, postStatementSqlBinds, createFuncs);
+        } catch (Exception e) {
+            logger.error(e.getMessage(), e);
+            throw e;
         } finally {
             if (con != null) {
                 try {