You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ke...@apache.org on 2021/09/08 12:08:10 UTC
[dolphinscheduler] branch dev updated (1f838e6 -> 9d7f70b)
This is an automated email from the ASF dual-hosted git repository.
kerwin pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git.
from 1f838e6 Merge pull request #6124 from apache/json_split_two
new 79952d9 [Feature][SPI] Task (#5996)
new 22c5292 [Feature][SPI] Task (#6044)
new b04bceb [Feature-5992] Enhance using experience of DataX in DS by integeration with TIS (#6015)
new 5a12e00 [Feature][Task]Task plugin spi (#6084)
new 4715de1 [Feature][Plugin]Task (#6105)
new 36d60a5 [Feature][Task]Task plugin spi (#6116)
new a288e6c [Plugin][Task]Task Spi (#6118)
new 9508d1e [SPI][TASK]TaskPlugin (#6122)
new 1804788 fix task plugin shell exec (#6128)
new dbb4adf Merge remote-tracking branch 'upstream/dev' into task-end
new 2dd5279 Merge remote-tracking branch 'upstream/dev' into task-end
new ac8fafa fix code style
new d6d3980 fix code style
new 5b98ea0 fix code style
new 9d7f70b Merge pull request #6133 from CalvinKirs/task-end
The 5200 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../dingtalk/DingTalkAlertChannelFactory.java | 4 +-
.../alert/email/EmailAlertChannelFactory.java | 4 +-
.../plugin/alert/email/EmailAlertChannelTest.java | 7 +-
.../alert/feishu/FeiShuAlertChannelFactory.java | 4 +-
.../plugin/alert/http/HttpAlertChannelFactory.java | 2 +-
.../plugin/alert/http/HttpAlertChannelTest.java | 2 +-
.../alert/script/ScriptAlertChannelFactory.java | 4 +-
.../alert/slack/SlackAlertChannelFactory.java | 2 +-
.../alert/wechat/WeChatAlertChannelFactory.java | 4 +-
.../alert/plugin/EmailAlertPluginTest.java | 6 +-
.../api/controller/AlertGroupController.java | 22 +
.../dolphinscheduler/common/enums/PluginType.java | 3 +-
.../dolphinscheduler/common/utils/DateUtils.java | 32 ++
dolphinscheduler-dist/release-docs/LICENSE | 2 +-
.../src/main/provisio/dolphinscheduler.xml | 33 ++
dolphinscheduler-server/pom.xml | 1 +
.../master/runner/WorkflowExecuteThread.java | 22 +-
.../master/runner/task/CommonTaskProcessor.java | 6 +-
.../master/runner/task/ConditionTaskProcessor.java | 1 -
.../dolphinscheduler/server/utils/ParamUtils.java | 16 +-
.../server/worker/WorkerServer.java | 35 +-
.../cache/TaskExecutionContextCacheManager.java | 56 --
.../impl/TaskExecutionContextCacheManagerImpl.java | 76 ---
.../server/worker/config/WorkerConfig.java | 33 ++
.../server/worker/plugin/TaskPluginManager.java | 106 ++++
.../worker/processor/TaskExecuteProcessor.java | 44 +-
.../server/worker/processor/TaskKillProcessor.java | 24 +-
.../server/worker/runner/TaskExecuteThread.java | 84 ++-
.../server/worker/runner/WorkerManagerThread.java | 16 +-
.../server/worker/task/AbstractYarnTask.java | 95 ----
.../server/worker/task/CommandExecuteResult.java | 69 ---
.../server/worker/task/TaskManager.java | 80 ---
.../server/worker/task/TaskProps.java | 346 -------------
.../server/worker/task/python/PythonTask.java | 151 ------
.../server/worker/task/sql/SqlTask.java | 516 -------------------
.../generator/sources/MysqlSourceGenerator.java | 135 -----
.../generator/targets/HdfsTargetGenerator.java | 86 ----
.../generator/targets/HiveTargetGenerator.java | 91 ----
.../generator/targets/MysqlTargetGenerator.java | 115 -----
.../src/main/resources/worker.properties | 8 +
.../TaskExecutionContextCacheManagerTest.java | 58 ---
.../worker/processor/TaskExecuteProcessorTest.java | 15 +-
.../worker/processor/TaskKillProcessorTest.java | 122 -----
.../worker/runner/TaskExecuteThreadTest.java | 192 -------
.../worker/runner/WorkerManagerThreadTest.java | 192 -------
.../worker/shell/ShellCommandExecutorTest.java | 250 ---------
.../server/worker/sql/SqlExecutorTest.java | 144 ------
.../worker/task/PythonCommandExecutorTest.java | 80 ---
.../server/worker/task/ShellTaskReturnTest.java | 115 -----
.../server/worker/task/TaskManagerTest.java | 192 -------
.../server/worker/task/TaskParamsTest.java | 77 ---
.../server/worker/task/datax/DataxTaskTest.java | 493 ------------------
.../server/worker/task/http/HttpTaskTest.java | 206 --------
.../worker/task/procedure/ProcedureTaskTest.java | 119 -----
.../server/worker/task/shell/ShellTaskTest.java | 125 -----
.../server/worker/task/spark/SparkTaskTest.java | 134 -----
.../server/worker/task/sql/SqlTaskTest.java | 153 ------
.../server/worker/task/sqoop/SqoopTaskTest.java | 228 ---------
dolphinscheduler-service/pom.xml | 6 -
.../service/quartz/cron/CronUtils.java | 52 +-
dolphinscheduler-spi/pom.xml | 19 +-
.../spi/DolphinSchedulerPlugin.java | 9 +
.../spi/alert/AlertChannelFactory.java | 23 +-
.../UiChannelFactory.java} | 15 +-
.../dolphinscheduler/spi/enums/CommandType.java | 84 +++
.../base/FormType.java => enums/DataType.java} | 37 +-
.../FormType.java => enums/DbConnectType.java} | 26 +-
.../{utils/StringUtils.java => enums/DbType.java} | 48 +-
.../{params/base/FormType.java => enums/Flag.java} | 43 +-
.../FormType.java => enums/ResUploadType.java} | 30 +-
.../TaskTimeoutStrategy.java} | 50 +-
.../dolphinscheduler/spi/params/PasswordParam.java | 2 +-
.../spi/params/PluginParamsTransfer.java | 2 +-
.../dolphinscheduler/spi/params/base/FormType.java | 16 +-
.../spi/params/base/ParamsProps.java | 15 +
.../spi/params/base/PluginParams.java | 34 +-
.../params/base/{FormType.java => ResizeType.java} | 22 +-
.../dolphinscheduler/spi/params/base/Validate.java | 2 +-
.../CheckboxParam.java} | 66 ++-
.../spi/params/checkbox/CheckboxParamProps.java | 78 +++
.../{InputParam.java => fswitch/SwitchParam.java} | 66 ++-
.../spi/params/fswitch/SwitchParamProps.java | 156 ++++++
.../spi/params/{ => input}/InputParam.java | 60 ++-
.../spi/params/input/InputParamProps.java | 297 +++++++++++
.../number/InputNumberParam.java} | 66 ++-
.../params/input/number/InputNumberParamProps.java | 130 +++++
.../spi/params/{ => radio}/RadioParam.java | 73 ++-
.../RadioParamProps.java} | 38 +-
.../{RadioParam.java => select/SelectParam.java} | 83 +--
.../spi/params/select/SelectParamProps.java | 239 +++++++++
.../spi/task/AbstractParameters.java | 166 ++++++
.../dolphinscheduler/spi}/task/AbstractTask.java | 98 ++--
.../base/FormType.java => task/Direct.java} | 28 +-
.../dolphinscheduler/spi/task/ExecutionStatus.java | 162 ++++++
.../base/FormType.java => task/IParameters.java} | 39 +-
.../apache/dolphinscheduler/spi/task/Property.java | 142 +++++
.../ParamsProps.java => task/ResourceInfo.java} | 43 +-
.../base/FormType.java => task/TaskChannel.java} | 22 +-
.../FormType.java => task/TaskChannelFactory.java} | 21 +-
.../dolphinscheduler/spi/task/TaskConstants.java | 319 ++++++++++++
.../spi/task/TaskExecutionContextCacheManager.java | 69 +++
.../dolphinscheduler/spi/task/UdfFuncBean.java | 188 +++++++
.../spi/task/paramparser/BusinessTimeUtils.java | 78 +++
.../spi/task/paramparser}/ParamUtils.java | 55 +-
.../spi/task/paramparser/ParameterUtils.java | 269 ++++++++++
.../spi/task/paramparser/PlaceholderUtils.java | 103 ++++
.../paramparser/PropertyPlaceholderHelper.java | 255 +++++++++
.../spi/task/paramparser/TimePlaceholderUtils.java | 570 +++++++++++++++++++++
.../spi/task/request/DataxTaskRequest.java | 115 +++++
.../request/ProcedureTaskRequest.java} | 39 +-
.../spi/task/request/SQLTaskRequest.java | 80 +++
.../spi/task/request/SqoopTaskRequest.java | 115 +++++
.../spi/task/request/TaskRequest.java | 431 ++++++++++++++++
.../spi/utils/CollectionUtils.java | 320 ++++++++++++
.../dolphinscheduler/spi/utils/Constants.java | 20 +
.../dolphinscheduler/spi}/utils/DateUtils.java | 36 +-
.../dolphinscheduler/spi/utils/JSONUtils.java | 172 ++++++-
.../dolphinscheduler/spi/utils/PropertyUtils.java | 260 ++++++++++
.../dolphinscheduler/spi/utils/StringUtils.java | 195 ++++++-
.../spi/params/PluginParamsTransferTest.java | 56 +-
.../dolphinscheduler-task-api/pom.xml | 278 ++++++++++
.../plugin/task/api}/AbstractCommandExecutor.java | 221 ++++----
.../plugin/task/api/AbstractShell.java | 360 +++++++++++++
.../plugin/task/api/AbstractTaskExecutor.java | 63 +++
.../plugin/task/api/AbstractYarnTask.java | 89 ++++
.../plugin/task/api/ProcessUtils.java | 336 ++++++++++++
.../plugin/task/api}/ShellCommandExecutor.java | 62 +--
.../plugin/task/api/ShellExecutor.java | 179 +++++++
.../plugin/task/api/TaskException.java | 23 +-
.../plugin/task/api/TaskResponse.java | 124 +++++
.../plugin/task/api/TaskRunStatus.java | 22 +-
.../datasource/AbstractDatasourceProcessor.java | 79 +++
.../task/datasource/BaseConnectionParam.java | 108 ++++
.../task/datasource/BaseDataSourceParamDTO.java | 161 ++++++
.../task/datasource/BaseHdfsConnectionParam.java | 57 +++
.../datasource/BaseHdfsDatasourceParamDTO.java | 61 +++
.../plugin/task/datasource/ConnectionParam.java | 24 +-
.../task/datasource/DatasourceProcessor.java | 81 +++
.../plugin/task/datasource/DatasourceUtil.java | 121 +++++
.../plugin/task/datasource/HiveConfUtils.java | 87 ++++
.../plugin/task/datasource/PasswordUtils.java | 88 ++++
.../clickhouse/ClickHouseDatasourceParamDTO.java | 37 +-
.../clickhouse/ClickHouseDatasourceProcessor.java | 131 +++++
.../clickhouse/ClickhouseConnectionParam.java | 33 +-
.../task/datasource/db2/Db2ConnectionParam.java | 33 +-
.../task/datasource/db2/Db2DatasourceParamDTO.java | 39 +-
.../datasource/db2/Db2DatasourceProcessor.java | 132 +++++
.../task/datasource/hive/HiveConnectionParam.java | 38 ++
.../datasource/hive/HiveDataSourceParamDTO.java | 45 ++
.../datasource/hive/HiveDatasourceProcessor.java | 192 +++++++
.../datasource/mysql/MysqlConnectionParam.java | 32 +-
.../datasource/mysql/MysqlDatasourceParamDTO.java | 39 +-
.../datasource/mysql/MysqlDatasourceProcessor.java | 176 +++++++
.../datasource/oracle/OracleConnectionParam.java | 47 ++
.../oracle/OracleDatasourceParamDTO.java | 55 ++
.../oracle/OracleDatasourceProcessor.java | 149 ++++++
.../postgresql/PostgreSqlConnectionParam.java | 33 +-
.../postgresql/PostgreSqlDatasourceParamDTO.java | 37 +-
.../postgresql/PostgreSqlDatasourceProcessor.java | 132 +++++
.../datasource/presto/PrestoConnectionParam.java | 33 +-
.../presto/PrestoDatasourceParamDTO.java | 39 +-
.../presto/PrestoDatasourceProcessor.java | 134 +++++
.../datasource/spark/SparkConnectionParam.java | 38 ++
.../datasource/spark/SparkDatasourceParamDTO.java | 45 ++
.../datasource/spark/SparkDatasourceProcessor.java | 161 ++++++
.../sqlserver/SqlServerConnectionParam.java | 33 +-
.../sqlserver/SqlServerDatasourceParamDTO.java | 43 ++
.../sqlserver/SqlServerDatasourceProcessor.java | 129 +++++
.../plugin/task/util/ArgsUtils.java | 22 +-
.../plugin/task/util/CommonUtils.java | 106 ++++
.../plugin/task/util/LoggerUtils.java | 123 +++++
.../plugin/task/util/MapUtils.java | 21 +-
.../dolphinscheduler/plugin/task/util/OSUtils.java | 91 ++++
.../plugin/task/util/ThreadUtils.java | 257 ++++++++++
.../dolphinscheduler/task/plugin/api/TaskTest.java | 20 +-
.../dolphinscheduler-task-datax/pom.xml | 54 ++
.../plugin/task/datax/DataxParameters.java | 251 +++++++++
.../plugin}/task/datax/DataxTask.java | 96 ++--
.../plugin/task/datax/DataxTaskChannel.java | 24 +-
.../plugin/task/datax/DataxTaskChannelFactory.java | 31 +-
.../plugin/task/datax/DataxTaskPlugin.java | 23 +-
.../plugin/task/datax/DataxUtils.java | 136 +++++
.../dolphinscheduler-task-flink/pom.xml | 47 ++
.../plugin/task/flink/FlinkArgsUtils.java | 136 +++++
.../plugin/task/flink/FlinkConstants.java | 42 ++
.../plugin/task/flink/FlinkParameters.java | 240 +++++++++
.../plugin}/task/flink/FlinkTask.java | 47 +-
.../plugin/task/flink/FlinkTaskChannel.java | 23 +-
.../plugin/task/flink/FlinkTaskChannelFactory.java | 30 +-
.../plugin/task/flink/FlinkTaskPlugin.java | 24 +-
.../plugin/task/flink/ProgramType.java | 30 +-
.../dolphinscheduler-task-http/pom.xml | 58 +++
.../plugin/task/http/HttpCheckCondition.java | 30 +-
.../plugin/task/http/HttpMethod.java | 32 +-
.../plugin/task/http/HttpParameters.java | 133 +++++
.../plugin/task/http/HttpParametersType.java | 30 +-
.../plugin/task/http/HttpProperty.java | 122 +++++
.../plugin}/task/http/HttpTask.java | 55 +-
.../plugin/task/http/HttpTaskChannel.java | 24 +-
.../plugin/task/http/HttpTaskChannelFactory.java | 31 +-
.../plugin/task/http/HttpTaskConstants.java | 21 +-
.../plugin/task/http/HttpTaskPlugin.java | 23 +-
.../dolphinscheduler-task-mr/pom.xml | 49 ++
.../plugin/task/mr/MapReduceArgsUtils.java | 88 ++++
.../plugin/task/mr/MapReduceParameters.java | 159 ++++++
.../plugin}/task/mr/MapReduceTask.java | 48 +-
.../plugin/task/mr/MapReduceTaskChannel.java | 24 +-
.../task/mr/MapReduceTaskChannelFactory.java | 31 +-
.../plugin/task/mr/MapReduceTaskConstants.java | 28 +-
.../plugin/task/mr/MapReduceTaskPlugin.java | 23 +-
.../plugin/task/mr/ProgramType.java | 30 +-
.../dolphinscheduler-task-procedure/pom.xml | 48 ++
.../plugin/task/procedure/ProcedureParameters.java | 89 ++++
.../plugin}/task/procedure/ProcedureTask.java | 69 ++-
.../task/procedure/ProcedureTaskChannel.java | 24 +-
.../procedure/ProcedureTaskChannelFactory.java | 31 +-
.../plugin/task/procedure/ProcedureTaskPlugin.java | 23 +-
.../dolphinscheduler-task-python/pom.xml | 47 ++
.../plugin/task/python}/PythonCommandExecutor.java | 120 ++---
.../plugin/task/python/PythonConstants.java | 29 +-
.../plugin/task/python/PythonParameters.java | 61 +++
.../plugin/task/python/PythonTask.java | 154 ++++++
.../plugin/task/python/PythonTaskChannel.java | 23 +-
.../task/python/PythonTaskChannelFactory.java | 32 +-
.../plugin/task/python/PythonTaskPlugin.java | 23 +-
.../dolphinscheduler-task-shell/pom.xml | 52 ++
.../plugin/task/shell/ShellParameters.java | 62 +++
.../plugin}/task/shell/ShellTask.java | 58 +--
.../plugin/task/shell/ShellTaskChannel.java | 23 +-
.../plugin/task/shell/ShellTaskChannelFactory.java | 45 +-
.../plugin/task/shell/ShellTaskPlugin.java | 23 +-
.../dolphinscheduler-task-spark/pom.xml | 46 ++
.../plugin/task/spark/ProgramType.java | 31 +-
.../plugin/task/spark/SparkArgsUtils.java | 129 +++++
.../plugin/task/spark/SparkConstants.java | 73 +++
.../plugin/task/spark/SparkParameters.java | 241 +++++++++
.../plugin}/task/spark/SparkTask.java | 46 +-
.../plugin/task/spark/SparkTaskChannel.java | 23 +-
.../plugin/task/spark/SparkTaskChannelFactory.java | 30 +-
.../task/spark/SparkTaskChannelFanctory.java | 30 +-
.../plugin/task/spark/SparkTaskPlugin.java | 23 +-
.../plugin/task/spark/SparkVersion.java | 30 +-
.../dolphinscheduler-task-sql/pom.xml | 46 ++
.../dolphinscheduler-task-sqoop/pom.xml | 48 ++
.../plugin}/task/sqoop/SqoopConstants.java | 2 +-
.../plugin/task/sqoop/SqoopJobType.java | 26 +-
.../plugin/task/sqoop/SqoopQueryType.java | 25 +-
.../plugin}/task/sqoop/SqoopTask.java | 43 +-
.../plugin/task/sqoop/SqoopTaskChannel.java | 24 +-
.../plugin/task/sqoop/SqoopTaskChannelFactory.java | 31 +-
.../plugin/task/sqoop/SqoopTaskPlugin.java | 23 +-
.../task/sqoop/generator/CommonGenerator.java | 35 +-
.../task/sqoop/generator/ISourceGenerator.java | 8 +-
.../task/sqoop/generator/ITargetGenerator.java | 8 +-
.../task/sqoop/generator/SqoopJobGenerator.java | 22 +-
.../generator/sources/HdfsSourceGenerator.java | 25 +-
.../generator/sources/HiveSourceGenerator.java | 40 +-
.../generator/sources/MysqlSourceGenerator.java | 147 ++++++
.../generator/targets/HdfsTargetGenerator.java | 93 ++++
.../generator/targets/HiveTargetGenerator.java | 101 ++++
.../generator/targets/MysqlTargetGenerator.java | 123 +++++
.../task/sqoop/parameter/SqoopParameters.java | 204 ++++++++
.../parameter/sources/SourceHdfsParameter.java | 27 +-
.../parameter/sources/SourceHiveParameter.java | 73 +++
.../parameter/sources/SourceMysqlParameter.java | 137 +++++
.../parameter/targets/TargetHdfsParameter.java | 98 ++++
.../parameter/targets/TargetHiveParameter.java | 121 +++++
.../parameter/targets/TargetMysqlParameter.java | 133 +++++
.../dolphinscheduler-task-tis}/pom.xml | 93 ++--
.../dolphinscheduler-task-tis/readme.md | 0
.../plugin/task/tis/TISParameters.java | 62 +++
.../plugin/task/tis/TISParamsConstants.java | 21 +-
.../dolphinscheduler/plugin/task/tis/TISTask.java | 348 +++++++++++++
.../plugin/task/tis/TISTaskChannel.java | 24 +-
.../plugin/task/tis/TISTaskChannelFactory.java | 51 ++
.../plugin/task/tis/TISTaskTest.java | 135 +++++
.../plugin/task/tis/TISTaskTest.json | 60 +++
dolphinscheduler-task-plugin/pom.xml | 46 ++
.../src/js/conf/home/pages/dag/_source/config.js | 4 +
.../home/pages/dag/_source/formModel/tasks/tis.vue | 225 ++++++++
.../src/js/conf/home/pages/dag/img/toolbar_TIS.svg | 46 ++
pom.xml | 2 +
tools/dependencies/known-dependencies.txt | 4 +-
283 files changed, 16651 insertions(+), 7034 deletions(-)
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/cache/TaskExecutionContextCacheManager.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/cache/impl/TaskExecutionContextCacheManagerImpl.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/plugin/TaskPluginManager.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractYarnTask.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/CommandExecuteResult.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/TaskManager.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/TaskProps.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/python/PythonTask.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/sources/MysqlSourceGenerator.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/targets/HdfsTargetGenerator.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/targets/HiveTargetGenerator.java
delete mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/targets/MysqlTargetGenerator.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/cache/TaskExecutionContextCacheManagerTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/processor/TaskKillProcessorTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThreadTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/runner/WorkerManagerThreadTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/shell/ShellCommandExecutorTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/sql/SqlExecutorTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/PythonCommandExecutorTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/ShellTaskReturnTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/TaskManagerTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/TaskParamsTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/datax/DataxTaskTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/http/HttpTaskTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/procedure/ProcedureTaskTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/shell/ShellTaskTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/spark/SparkTaskTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTaskTest.java
delete mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/sqoop/SqoopTaskTest.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{alert/AlertChannelFactory.java => common/UiChannelFactory.java} (80%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/enums/CommandType.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => enums/DataType.java} (67%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => enums/DbConnectType.java} (65%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{utils/StringUtils.java => enums/DbType.java} (51%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => enums/Flag.java} (61%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => enums/ResUploadType.java} (69%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/ParamsProps.java => enums/TaskTimeoutStrategy.java} (51%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/{FormType.java => ResizeType.java} (74%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/{InputParam.java => checkbox/CheckboxParam.java} (70%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/checkbox/CheckboxParamProps.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/{InputParam.java => fswitch/SwitchParam.java} (70%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/fswitch/SwitchParamProps.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/{ => input}/InputParam.java (74%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/input/InputParamProps.java
rename dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/{InputParam.java => input/number/InputNumberParam.java} (69%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/input/number/InputNumberParamProps.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/{ => radio}/RadioParam.java (66%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/{base/ParamsProps.java => radio/RadioParamProps.java} (53%)
rename dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/{RadioParam.java => select/SelectParam.java} (60%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/select/SelectParamProps.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/AbstractParameters.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi}/task/AbstractTask.java (61%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => task/Direct.java} (69%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/ExecutionStatus.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => task/IParameters.java} (67%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/Property.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/ParamsProps.java => task/ResourceInfo.java} (57%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => task/TaskChannel.java} (69%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/FormType.java => task/TaskChannelFactory.java} (69%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/TaskConstants.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/TaskExecutionContextCacheManager.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/UdfFuncBean.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/BusinessTimeUtils.java
copy {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils => dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser}/ParamUtils.java (73%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/ParameterUtils.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/PlaceholderUtils.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/PropertyPlaceholderHelper.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/TimePlaceholderUtils.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/request/DataxTaskRequest.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/{params/base/ParamsProps.java => task/request/ProcedureTaskRequest.java} (57%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/request/SQLTaskRequest.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/request/SqoopTaskRequest.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/request/TaskRequest.java
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/CollectionUtils.java
copy {dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common => dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi}/utils/DateUtils.java (94%)
create mode 100644 dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/PropertyUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/pom.xml
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api}/AbstractCommandExecutor.java (62%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/AbstractShell.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/AbstractTaskExecutor.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/AbstractYarnTask.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/ProcessUtils.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api}/ShellCommandExecutor.java (59%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/ShellExecutor.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/TaskException.java (68%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/TaskResponse.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/TaskRunStatus.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/AbstractDatasourceProcessor.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/BaseConnectionParam.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/BaseDataSourceParamDTO.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/BaseHdfsConnectionParam.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/BaseHdfsDatasourceParamDTO.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/ConnectionParam.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/DatasourceProcessor.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/DatasourceUtil.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/HiveConfUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/PasswordUtils.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/clickhouse/ClickHouseDatasourceParamDTO.java (52%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/clickhouse/ClickHouseDatasourceProcessor.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/clickhouse/ClickhouseConnectionParam.java (56%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/db2/Db2ConnectionParam.java (57%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/db2/Db2DatasourceParamDTO.java (50%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/db2/Db2DatasourceProcessor.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/hive/HiveConnectionParam.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/hive/HiveDataSourceParamDTO.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/hive/HiveDatasourceProcessor.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/mysql/MysqlConnectionParam.java (57%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/mysql/MysqlDatasourceParamDTO.java (50%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/mysql/MysqlDatasourceProcessor.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/oracle/OracleConnectionParam.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/oracle/OracleDatasourceParamDTO.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/oracle/OracleDatasourceProcessor.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/postgresql/PostgreSqlConnectionParam.java (56%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/postgresql/PostgreSqlDatasourceParamDTO.java (52%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/postgresql/PostgreSqlDatasourceProcessor.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/presto/PrestoConnectionParam.java (57%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/presto/PrestoDatasourceParamDTO.java (50%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/presto/PrestoDatasourceProcessor.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/spark/SparkConnectionParam.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/spark/SparkDatasourceParamDTO.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/spark/SparkDatasourceProcessor.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/sqlserver/SqlServerConnectionParam.java (56%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/sqlserver/SqlServerDatasourceParamDTO.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/datasource/sqlserver/SqlServerDatasourceProcessor.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/util/ArgsUtils.java (70%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/util/CommonUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/util/LoggerUtils.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/util/MapUtils.java (70%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/util/OSUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/util/ThreadUtils.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/task/plugin/api/TaskTest.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-datax/pom.xml
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxParameters.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin}/task/datax/DataxTask.java (87%)
mode change 100755 => 100644
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskChannel.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskChannelFactory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxTaskPlugin.java (64%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/pom.xml
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkArgsUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkConstants.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkParameters.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin}/task/flink/FlinkTask.java (71%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTaskChannel.java (66%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTaskChannelFactory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTaskPlugin.java (64%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/ProgramType.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-http/pom.xml
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpCheckCondition.java (69%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpMethod.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpParameters.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpParametersType.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpProperty.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin}/task/http/HttpTask.java (87%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpTaskChannel.java (63%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpTaskChannelFactory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpTaskConstants.java (69%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpTaskPlugin.java (65%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-mr/pom.xml
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin/task/mr/MapReduceArgsUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin/task/mr/MapReduceParameters.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin}/task/mr/MapReduceTask.java (70%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin/task/mr/MapReduceTaskChannel.java (63%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin/task/mr/MapReduceTaskChannelFactory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin/task/mr/MapReduceTaskConstants.java (64%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin/task/mr/MapReduceTaskPlugin.java (64%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-mr/src/main/java/org/apache/dolphinscheduler/plugin/task/mr/ProgramType.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/pom.xml
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureParameters.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin}/task/procedure/ProcedureTask.java (80%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTaskChannel.java (58%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTaskChannelFactory.java (58%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTaskPlugin.java (64%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-python/pom.xml
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task => dolphinscheduler-task-plugin/dolphinscheduler-task-python/src/main/java/org/apache/dolphinscheduler/plugin/task/python}/PythonCommandExecutor.java (51%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-python/src/main/java/org/apache/dolphinscheduler/plugin/task/python/PythonConstants.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-python/src/main/java/org/apache/dolphinscheduler/plugin/task/python/PythonParameters.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-python/src/main/java/org/apache/dolphinscheduler/plugin/task/python/PythonTask.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-python/src/main/java/org/apache/dolphinscheduler/plugin/task/python/PythonTaskChannel.java (66%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-python/src/main/java/org/apache/dolphinscheduler/plugin/task/python/PythonTaskChannelFactory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-python/src/main/java/org/apache/dolphinscheduler/plugin/task/python/PythonTaskPlugin.java (64%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-shell/pom.xml
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-shell/src/main/java/org/apache/dolphinscheduler/plugin/task/shell/ShellParameters.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-shell/src/main/java/org/apache/dolphinscheduler/plugin}/task/shell/ShellTask.java (74%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-shell/src/main/java/org/apache/dolphinscheduler/plugin/task/shell/ShellTaskChannel.java (66%)
copy dolphinscheduler-alert-plugin/dolphinscheduler-alert-slack/src/main/java/org/apache/dolphinscheduler/plugin/alert/slack/SlackAlertChannelFactory.java => dolphinscheduler-task-plugin/dolphinscheduler-task-shell/src/main/java/org/apache/dolphinscheduler/plugin/task/shell/ShellTaskChannelFactory.java (53%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-shell/src/main/java/org/apache/dolphinscheduler/plugin/task/shell/ShellTaskPlugin.java (64%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-spark/pom.xml
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/ProgramType.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkArgsUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkConstants.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkParameters.java
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin}/task/spark/SparkTask.java (72%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkTaskChannel.java (63%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkTaskChannelFactory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkTaskChannelFanctory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkTaskPlugin.java (64%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-spark/src/main/java/org/apache/dolphinscheduler/plugin/task/spark/SparkVersion.java (64%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sql/pom.xml
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/pom.xml
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/SqoopConstants.java (98%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/SqoopJobType.java (67%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/SqoopQueryType.java (66%)
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/SqoopTask.java (65%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/SqoopTaskChannel.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/utils/StringUtils.java => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/SqoopTaskChannelFactory.java (59%)
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/SqoopTaskPlugin.java (64%)
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/generator/CommonGenerator.java (66%)
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/generator/ISourceGenerator.java (77%)
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/generator/ITargetGenerator.java (77%)
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/generator/SqoopJobGenerator.java (80%)
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/generator/sources/HdfsSourceGenerator.java (65%)
rename {dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin}/task/sqoop/generator/sources/HiveSourceGenerator.java (53%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/generator/sources/MysqlSourceGenerator.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/generator/targets/HdfsTargetGenerator.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/generator/targets/HiveTargetGenerator.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/generator/targets/MysqlTargetGenerator.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/parameter/SqoopParameters.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/parameter/sources/SourceHdfsParameter.java (70%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/parameter/sources/SourceHiveParameter.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/parameter/sources/SourceMysqlParameter.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/parameter/targets/TargetHdfsParameter.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/parameter/targets/TargetHiveParameter.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-sqoop/src/main/java/org/apache/dolphinscheduler/plugin/task/sqoop/parameter/targets/TargetMysqlParameter.java
copy {dolphinscheduler-service => dolphinscheduler-task-plugin/dolphinscheduler-task-tis}/pom.xml (55%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-tis/readme.md
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-tis/src/main/java/org/apache/dolphinscheduler/plugin/task/tis/TISParameters.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-tis/src/main/java/org/apache/dolphinscheduler/plugin/task/tis/TISParamsConstants.java (70%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-tis/src/main/java/org/apache/dolphinscheduler/plugin/task/tis/TISTask.java
copy dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/FormType.java => dolphinscheduler-task-plugin/dolphinscheduler-task-tis/src/main/java/org/apache/dolphinscheduler/plugin/task/tis/TISTaskChannel.java (63%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-tis/src/main/java/org/apache/dolphinscheduler/plugin/task/tis/TISTaskChannelFactory.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-tis/src/test/java/org/apache/dolphinscheduler/plugin/task/tis/TISTaskTest.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-tis/src/test/resources/org/apache/dolphinscheduler/plugin/task/tis/TISTaskTest.json
create mode 100644 dolphinscheduler-task-plugin/pom.xml
create mode 100755 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/tis.vue
create mode 100644 dolphinscheduler-ui/src/js/conf/home/pages/dag/img/toolbar_TIS.svg