This is an automated email from the ASF dual-hosted git repository.
leonbao pushed a change to branch json_split
in repository
https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git.
from fc6461c [Feature][JsonSplit]modify mysql.sql. remove dumplicate
locations (#4582)
add afd201e [FIX-#4592]Fix that the worker group management IP is not
displayed correctly. (#4620)
add e083e28 [Improvement][service] Refactor service module to fix code
smell (#4513)
add ad82bb0 fix ui datasource dialog visible. (#4597)
add e54e423 Review readme (#4614)
add 0e43b0d Remove duplicate license(LICENSE-@form-create-element-ui )
(#4630)
add d80f061 [Feature-#4350][Alert]support feishu plugin (#4594)
add 09feb5c change DS introduction in the README.md 'multiple types'
to'various types' (#4632)
add 25cbcc1 [BUG][Alert]fix alert plugin DingTalkSender (#4629)
add 8780708 removed issue label (#4623)
add ab724f6 [Fix][sql] Postgresql sql script error (#4595)
add 047b0a3 [Improvement][remote] Refactor remote module to fix code
smell (#4576)
new c8d5454 merge form dev
The 1 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:
.github/ISSUE_TEMPLATE/bug_report.md | 1 -
.github/ISSUE_TEMPLATE/feature_request.md | 1 -
.github/ISSUE_TEMPLATE/improvement_suggestion.md | 1 -
.github/ISSUE_TEMPLATE/question.md | 1 -
README.md | 54 +-
.../DOLPHIN/1.3.3/configuration/dolphin-worker.xml | 109 ++--
.../alert/dingtalk/DingTalkParamsConstants.java | 44 +-
.../plugin/alert/dingtalk/DingTalkSender.java | 132 ++---
.../plugin/alert/dingtalk/DingTalkSenderTest.java | 2 +-
.../pom.xml | 4 +-
.../plugin/alert/feishu/FeiShuAlertChannel.java} | 10 +-
.../alert/feishu/FeiShuAlertChannelFactory.java | 82 +++
.../plugin/alert/feishu/FeiShuAlertPlugin.java} | 10 +-
.../alert/feishu/FeiShuParamsConstants.java} | 33 +-
.../plugin/alert/feishu/FeiShuSender.java | 223 ++++++++
.../plugin/alert/feishu/HttpRequestUtil.java | 50 ++
.../feishu/FeiShuAlertChannelFactoryTest.java} | 15 +-
.../plugin/alert/feishu/FeiShuSenderTest.java | 75 +++
dolphinscheduler-alert-plugin/pom.xml | 1 +
.../api/service/WorkerGroupService.java | 12 +-
.../dolphinscheduler/common/utils/StringUtils.java | 4 +
.../src/main/provisio/dolphinscheduler.xml | 5 +
.../remote/NettyRemotingClient.java | 150 +++--
.../remote/NettyRemotingServer.java | 64 ++-
.../remote/codec/NettyEncoder.java | 12 +-
.../remote/command/TaskKillResponseCommand.java | 6 +-
.../remote/exceptions/RemoteException.java | 16 +-
.../remote/future/ResponseFuture.java | 63 ++-
.../remote/handler/NettyClientHandler.java | 34 +-
.../remote/handler/NettyServerHandler.java | 40 +-
.../remote/utils/ChannelUtils.java | 31 +-
.../dolphinscheduler/remote/utils/Constants.java | 4 +
.../dolphinscheduler/remote/utils/IPUtils.java | 25 +-
.../apache/dolphinscheduler/remote/utils/Pair.java | 5 +-
.../service/bean/SpringApplicationContext.java | 5 +-
...tyQueueException.java => ServiceException.java} | 30 +-
.../service/permission/PermissionCheck.java | 48 +-
.../service/process/ProcessService.java | 307 +++++------
.../service/quartz/ProcessScheduleJob.java | 15 +-
.../service/quartz/QuartzExecutors.java | 614 +++++++++++----------
.../service/quartz/cron/AbstractCycle.java | 302 +++++-----
.../service/zk/AbstractZKClient.java | 611 ++++++++++----------
.../service/zk/CuratorZookeeperClient.java | 22 +-
.../dolphinscheduler/service/zk/ZKServer.java | 37 +-
.../service/zk/ZookeeperCachedOperator.java | 20 +-
.../service/zk/ZookeeperOperator.java | 45 +-
.../home/pages/datasource/pages/list/index.vue | 1 +
pom.xml | 2 +
.../postgresql/dolphinscheduler_ddl.sql | 7 +-
.../postgresql/dolphinscheduler_ddl.sql | 12 +-
50 files changed, 1941 insertions(+), 1456 deletions(-)
copy dolphinscheduler-alert-plugin/{dolphinscheduler-alert-dingtalk =>
dolphinscheduler-alert-feishu}/pom.xml (94%)
copy
dolphinscheduler-alert-plugin/{dolphinscheduler-alert-http/src/main/java/org/apache/dolphinscheduler/plugin/alert/http/HttpAlertChannel.java
=>
dolphinscheduler-alert-feishu/src/main/java/org/apache/dolphinscheduler/plugin/alert/feishu/FeiShuAlertChannel.java}
(84%)
create mode 100644
dolphinscheduler-alert-plugin/dolphinscheduler-alert-feishu/src/main/java/org/apache/dolphinscheduler/plugin/alert/feishu/FeiShuAlertChannelFactory.java
copy
dolphinscheduler-alert-plugin/{dolphinscheduler-alert-http/src/main/java/org/apache/dolphinscheduler/plugin/alert/http/HttpAlertPlugin.java
=>
dolphinscheduler-alert-feishu/src/main/java/org/apache/dolphinscheduler/plugin/alert/feishu/FeiShuAlertPlugin.java}
(83%)
copy
dolphinscheduler-alert-plugin/{dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptParamsConstants.java
=>
dolphinscheduler-alert-feishu/src/main/java/org/apache/dolphinscheduler/plugin/alert/feishu/FeiShuParamsConstants.java}
(52%)
create mode 100644
dolphinscheduler-alert-plugin/dolphinscheduler-alert-feishu/src/main/java/org/apache/dolphinscheduler/plugin/alert/feishu/FeiShuSender.java
create mode 100644
dolphinscheduler-alert-plugin/dolphinscheduler-alert-feishu/src/main/java/org/apache/dolphinscheduler/plugin/alert/feishu/HttpRequestUtil.java
copy
dolphinscheduler-alert-plugin/{dolphinscheduler-alert-wechat/src/test/java/org/apache/dolphinscheduler/plugin/alert/wechat/WeChatAlertChannelFactoryTest.java
=>
dolphinscheduler-alert-feishu/src/test/java/org/apache/dolphinscheduler/plugin/alert/feishu/FeiShuAlertChannelFactoryTest.java}
(73%)
create mode 100644
dolphinscheduler-alert-plugin/dolphinscheduler-alert-feishu/src/test/java/org/apache/dolphinscheduler/plugin/alert/feishu/FeiShuSenderTest.java
copy
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/exceptions/TaskPriorityQueueException.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/exceptions/RemoteException.java
(74%)
copy
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/exceptions/{TaskPriorityQueueException.java
=> ServiceException.java} (63%)
