Browse Source

[Bug] [Task] SQL task no exception stack trace in task log (#10656)

3.1.0-release
zhuxt2015 2 years ago committed by GitHub
parent
commit
7e7df1d8ff
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java
  2. 2
      dolphinscheduler-task-plugin/dolphinscheduler-task-sql/src/main/java/org/apache/dolphinscheduler/plugin/task/sql/SqlTask.java

1
dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTask.java

@ -167,6 +167,7 @@ public class DataxTask extends AbstractTaskExecutor {
setAppIds(commandExecuteResult.getAppIds()); setAppIds(commandExecuteResult.getAppIds());
setProcessId(commandExecuteResult.getProcessId()); setProcessId(commandExecuteResult.getProcessId());
} catch (Exception e) { } catch (Exception e) {
logger.error("datax task error", e);
setExitStatusCode(EXIT_CODE_FAILURE); setExitStatusCode(EXIT_CODE_FAILURE);
throw e; throw e;
} }

2
dolphinscheduler-task-plugin/dolphinscheduler-task-sql/src/main/java/org/apache/dolphinscheduler/plugin/task/sql/SqlTask.java

@ -162,7 +162,7 @@ public class SqlTask extends AbstractTaskExecutor {
} catch (Exception e) { } catch (Exception e) {
setExitStatusCode(TaskConstants.EXIT_CODE_FAILURE); setExitStatusCode(TaskConstants.EXIT_CODE_FAILURE);
logger.error("sql task error: {}", e.toString()); logger.error("sql task error", e);
throw e; throw e;
} }
} }

Loading…
Cancel
Save