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
