Browse Source

[Plugin][Task]Fix Sql Task NPE (#6290)

2.0.7-release
Kirs 3 years ago committed by GitHub
parent
commit
7e8febed4d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 16
      dolphinscheduler-task-plugin/dolphinscheduler-task-sql/src/main/java/org/apache/dolphinscheduler/plugin/task/sql/SqlTask.java

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

@ -17,7 +17,7 @@
package org.apache.dolphinscheduler.plugin.task.sql; package org.apache.dolphinscheduler.plugin.task.sql;
import org.apache.dolphinscheduler.plugin.task.api.AbstractYarnTask; import org.apache.dolphinscheduler.plugin.task.api.AbstractTaskExecutor;
import org.apache.dolphinscheduler.plugin.task.api.TaskException; import org.apache.dolphinscheduler.plugin.task.api.TaskException;
import org.apache.dolphinscheduler.plugin.task.datasource.BaseConnectionParam; import org.apache.dolphinscheduler.plugin.task.datasource.BaseConnectionParam;
import org.apache.dolphinscheduler.plugin.task.datasource.DatasourceUtil; import org.apache.dolphinscheduler.plugin.task.datasource.DatasourceUtil;
@ -59,7 +59,7 @@ import org.slf4j.Logger;
import com.fasterxml.jackson.databind.node.ArrayNode; import com.fasterxml.jackson.databind.node.ArrayNode;
import com.fasterxml.jackson.databind.node.ObjectNode; import com.fasterxml.jackson.databind.node.ObjectNode;
public class SqlTask extends AbstractYarnTask { public class SqlTask extends AbstractTaskExecutor {
/** /**
* taskExecutionContext * taskExecutionContext
@ -99,17 +99,7 @@ public class SqlTask extends AbstractYarnTask {
@Override @Override
public AbstractParameters getParameters() { public AbstractParameters getParameters() {
return null; return sqlParameters;
}
@Override
protected String buildCommand() {
return null;
}
@Override
protected void setMainJarName() {
} }
@Override @Override

Loading…
Cancel
Save